我正在尝试使用 google-provided template
设置一个数据流管道,将 protobufs 从 Pub/Sub 传输到 BigQuery 。
我需要通过 UDF 运行它,但我不确定如何解析传入的消息。加载原型时,例如在下面,我指向哪里?GCS 中的地址?
const root = protobuf.load("address/to/definition.proto")
谢谢!
我正在尝试使用 google-provided template
设置一个数据流管道,将 protobufs 从 Pub/Sub 传输到 BigQuery 。
我需要通过 UDF 运行它,但我不确定如何解析传入的消息。加载原型时,例如在下面,我指向哪里?GCS 中的地址?
const root = protobuf.load("address/to/definition.proto")
谢谢!