Вы должны включить текущую временную метку в приложение, которое создает структуру выходных данных. В некотором смысле это будет время события (вы можете добавить больше детализации, добавив время события на клиенте или на сервере в зависимости от того, как происходят ваши события).
Тогда вы, возможно, захотите записать время перед обработкой (сразу после прочтения сообщения из Pub / Sub). Затем вы хотите записать время прямо перед тем, как писать в BigQuery.
Вы можете сделать оба этих действия с DoFn в качестве дополнительного шага или включить его в качестве первого действия в первом преобразовании и последнего действия в последнем преобразовании, которое у вас есть в вашем конвейере.
Включить эти новые столбцы соответственно в схему таблицы выходной таблицы BigQuery.