Connector for BigQuery
使用集合让一切井井有条
根据您的偏好保存内容并对其进行分类。
定义用于在工作流内访问 BigQuery 的内置函数的 Workflows 连接器。
深入探索
如需查看包含此代码示例的详细文档,请参阅以下内容:
代码示例
如未另行说明,那么本页面中的内容已根据知识共享署名 4.0 许可获得了许可,并且代码示例已根据 Apache 2.0 许可获得了许可。有关详情,请参阅 Google 开发者网站政策。Java 是 Oracle 和/或其关联公司的注册商标。
[[["易于理解","easyToUnderstand","thumb-up"],["解决了我的问题","solvedMyProblem","thumb-up"],["其他","otherUp","thumb-up"]],[["很难理解","hardToUnderstand","thumb-down"],["信息或示例代码不正确","incorrectInformationOrSampleCode","thumb-down"],["没有我需要的信息/示例","missingTheInformationSamplesINeed","thumb-down"],["翻译问题","translationIssue","thumb-down"],["其他","otherDown","thumb-down"]],[],[],[],null,["# Connector for BigQuery\n\nWorkflows connector that defines the built-in function used to access BigQuery within a workflow.\n\nExplore further\n---------------\n\n\nFor detailed documentation that includes this code sample, see the following:\n\n- [BigQuery API Connector Overview](/workflows/docs/reference/googleapis/bigquery/Overview)\n\nCode sample\n-----------\n\n### YAML\n\n # This workflow demonstrates how to use the BigQuery connector:\n # Create a dataset and then insert a table with data from a public dataset\n # Delete both the table and dataset\n # Expected output: \"SUCCESS\"\n - init:\n assign:\n - project_id: ${sys.get_env(\"GOOGLE_CLOUD_PROJECT_ID\")}\n - dataset_id: \"example_dataset\"\n - table_id: \"example_table\"\n - query: \"SELECT * FROM `bigquery-public-data.usa_names.usa_1910_2013` LIMIT 5000;\"\n - create_disposition: \"CREATE_IF_NEEDED\" # creates table if it doesn't exist\n - write_disposition: \"WRITE_TRUNCATE\" # truncates table if it already exists\n - create_dataset:\n call: googleapis.bigquery.v2.datasets.insert\n args:\n projectId: ${project_id}\n body:\n datasetReference:\n datasetId: ${dataset_id}\n projectId: ${project_id}\n access[].role: \"roles/bigquery.dataViewer\"\n access[].specialGroup: \"projectReaders\"\n - insert_table_into_dataset:\n call: googleapis.bigquery.v2.jobs.insert\n args:\n projectId: ${project_id}\n body:\n configuration:\n query:\n query: ${query}\n destinationTable:\n projectId: ${project_id}\n datasetId: ${dataset_id}\n tableId: ${table_id}\n create_disposition: ${create_disposition}\n write_disposition: ${write_disposition}\n allowLargeResults: true\n useLegacySql: false\n - delete_table_from_dataset:\n call: googleapis.bigquery.v2.tables.delete\n args:\n projectId: ${project_id}\n datasetId: ${dataset_id}\n tableId: ${table_id}\n - delete_dataset:\n call: googleapis.bigquery.v2.datasets.delete\n args:\n projectId: ${project_id}\n datasetId: ${dataset_id}\n - the_end:\n return: \"SUCCESS\"\n\nWhat's next\n-----------\n\n\nTo search and filter code samples for other Google Cloud products, see the\n[Google Cloud sample browser](/docs/samples?product=workflows)."]]