I have a problem with writing custom sink with Python SDK. To debug it, I used logging.info or print method, but it could not work well. Are there any good way to debug custom sink?
使用Python SDK编写自定义接收器时遇到问题。为了调试它，我使用了logging.info或print方法，但它无法正常工作。有没有什么好方法可以调试自定义接收器？
1 个解决方案
#1
1
What problems did you have with logging?
伐木有什么问题？
When run with the Dataflow pipeline runner, the logs should be accessible in the Cloud Console as described in Logging Pipeline Messages.
使用Dataflow管道运行程序运行时，应在Cloud Console中访问日志，如记录管道消息中所述。
You can also use the direct runner to execute the pipeline locally, which may make it easier to debug.
您还可以使用direct runner在本地执行管道，这可以使调试更容易。
#1
1
What problems did you have with logging?
伐木有什么问题？
When run with the Dataflow pipeline runner, the logs should be accessible in the Cloud Console as described in Logging Pipeline Messages.
使用Dataflow管道运行程序运行时，应在Cloud Console中访问日志，如记录管道消息中所述。
You can also use the direct runner to execute the pipeline locally, which may make it easier to debug.
您还可以使用direct runner在本地执行管道，这可以使调试更容易。