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

Использование SCIO из spotify для написания задания для Dataflow , следуя 2 примерам например1 и e .g2 , чтобы записать PubSub поток в GCS , но получить следующую ошибку для приведенного ниже кода Ошибка Exception in thread...

У меня есть корзина GCS (Google Cloud Service) и тема Google PubSub, я хочу, чтобы события из этой корзины автоматически отправлялись в тему PubSub. Когда я запускаю эту команду gsutil notification create -t pubsub_topic_name -f json...