如何在 python 脚本中调试 KCL(python)？

Question

我为 python 消费者使用 KCL 库，但我不知道如何在 python 脚本中获取数据等？

它通过 MultiLangDaemon 工作并基于 java。我有一个 python 脚本，它在 java 之上运行（我在库中使用示例并使用 sample_kclpy_app.py），当我开始时 java （由 python) 我无法获取数据或打印数据。

如何通过 python 脚本调试它？我尝试并行启动 sample_kclpy_app.py 但没有任何反应。

Answer 1

Kinesis Client Library 通过 STDIN / STDOUT 在 Java 和 Python 之间进行通信，因此可以通过 Python 日志记录而不是使用 print 语句来执行调试指向文件的对象。例如，在 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。