首页 > 解决方案 > Apache Beam 记录带有错误标签的消息

问题描述

错误日志不会登录 GCP 控制台。
警告日志确实记录为信息(所以我一直在使用它们来记录信息消息)。例如,

test = "hello debug world" 
logging.warning("%s", test) # will log as info message in GCP dataflow console

信息日志也不登录控制台。

我正在使用 Apache Beam Python 3.7 SDK 2.23.0,但这似乎是一个老问题

Apache Beam SDK 本身也会发生这种情况,它有时会以信息的形式静默记录错​​误。

在此处输入图像描述

知道是什么原因造成的吗?似乎是 Apache Beam 方面的一个错误,而不是脚本错误。

标签: google-cloud-dataflowapache-beamapache-beam-io

解决方案


您必须将下拉值从 Info 更改为更高的日志级别才能查看ErrorWarning键入消息。在屏幕截图中,日志级别设置为 Info,您正在日志条目中搜索字符串错误,并且 stackdriver 正在根据它进行过滤。


推荐阅读