Процессор обработки выходных данных¶
Используется для преобразования и обработки данных, которые необходимо отправить во внешние системы.
Публичные методы¶
send_simple_msg_to_kafka¶
Метод, предназначенный для отправки сообщения в Kafka, через adg_kafka_connector
.
Параметры:
topic_name
– имя топика, куда производится отправка;key
– ключ сообщения;value
– значение сообщения.
send_messages_to_kafka¶
Метод, предназначенный для отправки набора сообщений в Kafka через adg_kafka_connector
.
Параметры:
topic_name
– имя топика, куда производится отправка;messages
– массив сообщений для отправки в Kafka;opts
– дополнительные опции отправки.
Возвращаемое значение:
- true – при успешной вставке;
- false,error – при ошибке.
send_query_to_kafka¶
Метод, предназначенный для отправки результата произвольного sql-запроса в Kafka через adg_kafka_connector
.
Параметры:
topic_name
– имя топика, куда производится отправка;query
– произвольный sql-запрос для выполнения на storage;opts
– дополнительные параметры.
send_table_to_kafka¶
Метод, предназначенный для отправки строк из конкретной таблицы в Kafka через adg_kafka_connector
.
Параметры:
topic_name
– имя топика, куда производится отправка;table
– спейс на storage для забора данных;filter
– фильтр на запрос к таблице;opts
– дополнительные параметры.
Возвращаемое значение:
- true – при успешной вставке;
- false,error – при ошибке.
get_metric¶
Метод, предназначенный для передачи метрик данной роли в систему сбора метрик.
Возвращаемое значение: Набор метрик в формате JSON.