Использование SCIO от spotify написать работу для Dataflow после 2 примера e.g1 и e.g2 написать PubSub поток в GCS, но получить следующее сообщение об ошибке для кода ниже Ошибка Exception in thread "
Я пытаюсь создать потоковое приложение потока данных, которое считывает события из Pub/Sub и записывает их в BigQuery. Согласно документации, Dataflow может обнаруживать дубликаты доставки сообщений,
Я использую Spotify Scio для чтения журналов, которые экспортируются из Stackdriver в Google Cloud Storage. Это файлы JSON, в которых каждая строка является отдельной записью. Глядя на рабочие журналы