我正在使用GCP处理和存储从模拟IoT设备发送的数据。数据(应该)在以下路径中流动: 带有mqtt客户端的模拟IoT设备-> IoT核心设备-> IoT核心注册表->发布/订阅主题->发布/订阅订阅->云数据流发布/订阅订阅BigQuery模板-> BigQuery表 我所在的公司有一些GCP配置(它在VPC上),这需要我指定一个subnet for DataFlow to even run。我还尝试了云数据流发布
我们有一个sql脚本,并希望在bigquery中使用BQ客户端从apache气流中执行它。我们正在使用python函数生成sql脚本。在运行此脚本时,如果有任何问题,请忽略它,只运行成功/有效语句。from google.cloud import bigqueryinsert into table1 select col2 from db.ta