Как получить идентификаторы заданий BigQuery для запросов, выполняемых через поток данных?

Question

Функция BigQueryIO.Read возвращает PCollection TableRow, но как мне получить идентификатор задания для только что выполненного запроса?

Возможно, я мог бы передать собственный идентификатор задания, но мне интересно, есть ли способ прочитать эту информацию из самой информации о задании потока данных.

Answer 1

Если вы посмотрите протоколирование, относящееся к операции чтения, PTransform запишет идентификатор задания BigQuery.В качестве примера см. Тестовое задание, которое я недавно выполнил: