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

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

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

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*.