我需要在Apache管道中运行一个对BigQuery的动态查询。应该根据消息中的值在运行时对查询进行评估。即select * from mytable where mycolumn = << dynamic value >>from apache_beam import Create, Pipeline
from apache_beam.io.gcp.bigquery
我试图导入google云和大型查询库,并遇到default credentials错误。我试图通过从云门户下载json文件并指定文件的路径来设置凭据。## Google Big Queryfrom google.cloud import bigquery/tmp/ipykernel_2944/216385