如何通过数据流获取查询 运行 的 BigQuery 作业 ID?

How do I get the BigQuery job IDs of queries run through dataflow?

BigQueryIO.Read 函数将 return TableRow 的 PCollection,但我如何才能获得该查询的作业 ID 运行?

可能有一种方法可以传递自定义作业 ID,但我想知道是否有任何方法可以从数据流作业信息本身读取此信息。

如果您查看与读取操作相关的日志记录,PT运行sform 将记录 BigQuery 作业 ID。举个例子,我最近 运行 的一个测试工作: