我用 Go 编写了一个数据流管道,它从 Pub/Sub 订阅中读取数据,执行转换,然后将记录写入 BigQuery。
它看起来运行良好,但我看不到 BigQuery 表中的数据。
查看管道并阅读日志,我看不到任何可以解释这一点的错误。如何调试 Dataflow 中失败的 BigQuery 插入?
我检查了工作日志,但没有看到任何 BQ 插入失败。
我唯一能找到错误消息的地方是我在
Output Pub/Sub topic