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

Question

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

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

如何通过 python 脚本调试它？我尝试并行启动 sample_kclpy_app.py，但什么也没发生。

Answer 1

Kinesis 客户端库通过 STDIN / STDOUT 在 Java 和 Python 之间进行通信，因此可以通过指向文件的 Python 日志记录对象来执行调试，而不是使用 print 语句。比如sample_kclpy_app.py内：

添加到导入部分：

import logging

添加到RecordProcessorinit方法：

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。