airflow.contrib.sensors.bigquery_sensor

Module Contents

class airflow.contrib.sensors.bigquery_sensor.BigQueryTableSensor(project_id, dataset_id, table_id, bigquery_conn_id='bigquery_default_conn', delegate_to=None, *args, **kwargs)[source]

Bases: airflow.sensors.base_sensor_operator.BaseSensorOperator

Checks for the existence of a table in Google Bigquery.

Parameters

  • project_id (str) – The Google cloud project in which to look for the table. The connection supplied to the hook must provide access to the specified project.

  • dataset_id (str) – The name of the dataset in which to look for the table. storage bucket.

  • table_id (str) – The name of the table to check the existence of.

  • bigquery_conn_id (str) – The connection ID to use when connecting to Google BigQuery.

  • delegate_to (str) – The account to impersonate, if any. For this to work, the service account making the request must have domain-wide delegation enabled.

template_fields = ['project_id', 'dataset_id', 'table_id'][source]
ui_color = #f0eee4[source]
poke(self, context)[source]

Was this entry helpful?