exporters

Модуль exporters содержит инструменты для экспорта данных во внешние системы через очередь.

В нем есть только одна функция для получения объекта-экспортёра по его имени:

1class BadParamsError(Exception):
2    pass
3
4class ExporterNotFoundError(Exception):
5    pass
6
7class UnknownError(Exception):
8    pass
9
10def get_by_name(name: str) -> Exporter:
11	pass

Сам объект-экспортер не отличается богатым интерфейсом, предоставляя лишь функцию отправки словаря в очередь:

1class Exporter:
2
3    def send(self, msg: Dict):
4        pass

Пример отправки значений в очередь с использованием данного модуля:

1from coiiot_sdk import exporters, context
2
3exporter = exporters.get_by_name("test_exporter")
4ctx = context.current()
5
6exporter.send({
7    "tag": ctx.tag.full_name,
8    "value": ctx.msg.value,
9    "timestamp": ctx.msg.timestamp,
10})