Как я могу отладить KCL (python) в скрипте Python?

Question

Я использую библиотеку KCL для потребителя Python, но я не знаю, как я могу получить данные и т. Д. В скрипте Python?

Работает через MultiLangDaemon и основан на Java. У меня есть скрипт Python, который работает над Java (я использую образцы в библиотеке и использую sample_kclpy_app.py), и когда я запускаю Java (который был сгенерирован Python), я не могу получить данные или напечатать данные.

Как я могу отладить его с помощью скрипта Python? Я попытался запустить sample_kclpy_app.py параллельно, но ничего не произошло.

Answer 1

Клиентская библиотека Kinesis обменивается данными между Java и Python через STDIN / STDOUT, поэтому вместо использования операторов print отладку можно выполнять с помощью объекта регистрации Python, направленного в файл. Например, в пределах sample_kclpy_app.py:

Добавить в раздел импорта:

import logging

Добавить в RecordProcessor init метод:

logging.basicConfig(filename='test.log',
        format='%(asctime)s %(levelname)-8s %(message)s',
        datefmt='%Y-%m-%d %H:%M:%S',
        level=logging.DEBUG)

Добавить к методу process_record (для простого примера регистрации):

logging.debug('Data: %s', data.decode('utf8'))

См. https://docs.python.org/3/library/logging.html для более подробной информации о модуле регистрации.