airflow.providers.google.cloud.links.bigquery¶

此模块包含 Google BigQuery 链接。

属性¶

airflow.providers.google.cloud.links.bigquery.BIGQUERY_BASE_LINK = '/bigquery'[source]¶

airflow.providers.google.cloud.links.bigquery.BIGQUERY_DATASET_LINK = '/bigquery?referrer=search&project={project_id}&d={dataset_id}&p={project_id}&page=dataset'[source]¶

airflow.providers.google.cloud.links.bigquery.BIGQUERY_TABLE_LINK = '/bigquery?referrer=search&project={project_id}&d={dataset_id}&p={project_id}&page=table&t={table_id}'[source]¶

airflow.providers.google.cloud.links.bigquery.BIGQUERY_JOB_DETAIL_LINK = '/bigquery?project={project_id}&ws=!1m5!1m4!1m3!1s{project_id}!2s{job_id}!3s{location}'[source]¶

class airflow.providers.google.cloud.links.bigquery.BigQueryDatasetLink[source]¶

用于构建 BigQuery 数据集链接的辅助类。

format_str = '/bigquery?referrer=search&project={project_id}&d={dataset_id}&p={project_id}&page=dataset'[source]¶

static persist(context, task_instance, dataset_id, project_id)[source]¶

class airflow.providers.google.cloud.links.bigquery.BigQueryTableLink[source]¶

用于构建 BigQuery 表链接的辅助类。

format_str = '/bigquery?referrer=search&project={project_id}&d={dataset_id}&p={project_id}&page=table&t={table_id}'[source]¶

static persist(context, task_instance, project_id, table_id, dataset_id=None)[source]¶

class airflow.providers.google.cloud.links.bigquery.BigQueryJobDetailLink[source]¶

用于构建 BigQuery 作业详情链接的辅助类。

format_str = '/bigquery?project={project_id}&ws=!1m5!1m4!1m3!1s{project_id}!2s{job_id}!3s{location}'[source]¶

static persist(context, task_instance, project_id, location, job_id)[source]¶