3 回答

• 0

  您可以尝试使用google-cloud-examples maven repo . 有一个名为 BigQuerySnippets 的类，它进行API调用以获取表元，您可以获取模式 . 请注意，限制API配额是每秒6个最大并发请求数 .

  回复于 2024-04-28T22:34:56+08:00
• 0

  Dataflow的目的是创建管道，因此不包括发出一些API请求的能力 . 您必须使用BigQuery Java客户端库来获取数据，然后将其提供给Apache Pipeline .

  DatasetId datasetId = DatasetId.of(projectId, datasetName);
  Page<Table> tables = bigquery.listTables(datasetId, TableListOption.pageSize(100));
  for (Table table : tables.iterateAll()) {
    // do something
  }
  

  回复于 2024-04-28T22:34:56+08:00
• 0

  声明库

  from google.cloud import bigquery
  

  准备一个bigquery客户端

  client = bigquery.Client(project='your_project_name')
  

  准备对新数据集的引用

  dataset_ref = client.dataset('your_data_set_name')
  

  发出API请求

  tables = list(client.list_tables(dataset_ref))
  if tables:
      for table in tables:
          print('\t{}'.format(table.table_id))
  

  参考：https://googlecloudplatform.github.io/google-cloud-python/latest/bigquery/usage.html#datasets

  回复于 2024-04-28T22:34:56+08:00