如何在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客户端库通过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。