Как извлечь значение из потока данных Pardo (DoFn) и использовать его для записи в местоположение gcs - PullRequest
0 голосов
/ 07 ноября 2019

У меня есть случай, когда сообщения json, опубликованные pubsub, читаются в задании потока данных. Затем в ParDo каждый элемент анализируется, и первые 4 ключа используются для создания имени файла в GCS. Оставшиеся ключи должны быть записаны в файл, расположенный в сформированном месте. Я не могу написать на место. Вы можете помочь?

...