Explicita usando a conexão padrão do Airflow

Execute uma tarefa ao configurar o Composer explicitamente para usar a conexão padrão do Airflow.

Mais informações

Para ver a documentação detalhada que inclui este exemplo de código, consulte:

Exemplo de código

Python

# Composer creates a 'google_cloud_default' connection by default.
task_explicit = bigquery.BigQueryInsertJobOperator(
    task_id='task_explicit_connection',
    gcp_conn_id='google_cloud_default',
    configuration={
        "query": {
            "query": 'SELECT 1',
            "useLegacySql": False
        }
    }
)

A seguir

Para pesquisar e filtrar amostras de código de outros produtos do Google Cloud, consulte a amostra de navegador do Google Cloud.