ฉันมีไปป์ไลน์กระแสข้อมูลที่รวบรวมข้อมูลผู้ใช้ เช่น การนำทาง การซื้อ การดำเนินการที่หยาบคาย ฯลฯ ฉันมีข้อกำหนดนี้เพื่อให้สามารถระบุรูปแบบแบบเรียลไทม์ จากนั้นจัดส่งเหตุการณ์ pubsub ที่บริการอื่นสามารถฟังเพื่อให้คำแนะนำแก่ผู้ใช้แบบเรียลไทม์...

การใช้ SCIO จาก spotify เพื่อเขียนงานสำหรับ Dataflow ตามตัวอย่าง 2 รายการ เช่นg1 และ e .g2 เพื่อเขียนสตรีม PubSub ไปที่ GCS แต่ได้รับข้อผิดพลาดต่อไปนี้สำหรับโค้ดด้านล่าง ข้อผิดพลาด Exception in thread "main"...

ฉันมีที่เก็บข้อมูล GCS (Google Cloud Service) และหัวข้อ Google PubSub ฉันต้องการให้กิจกรรมจากที่เก็บข้อมูลนี้ถูกส่งไปยังหัวข้อ PubSub โดยอัตโนมัติ เมื่อฉันรันคำสั่งนี้ gsutil notification create -t pubsub_topic_name -f json gs://bucket-name...