Python SDKでカスタムシンクをデバッグする方法

Question

Python SDKでカスタムシンクを作成する際に問題があります。 これをデバッグするには、logging.infoまたはprintメソッドを使用しましたが、うまく動作しませんでした。 カスタムシンクをデバッグする良い方法はありますか？

Answer 1

ログにはどのような問題がありましたか？

Dataflowパイプラインランナーで実行する場合、ログはCloud ConsoleでLogging Pipeline Messagesに記載されているようにアクセス可能である必要があります。

ダイレクトランナーを使用してパイプラインをローカルで実行することもできます。これにより、デバッグが容易になる場合があります。