Запуск задания потока данных при получении уведомления PubSub

# #google-cloud-platform #google-cloud-dataflow #apache-beam #google-cloud-pubsub Вопрос: Я написал конвейер потока данных с Apache Beam, чтобы дать вам базовое представление о коде: Job= ( p |"cretae">>beam.Create(["message"]) |"job 1" >> beam.ParDo(dofn1()) |"job…