Процессор обработки выходных данных

Используется для преобразования и обработки данных, которые необходимо отправить во внешние системы.

Публичные методы

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.