O Cloud Composer 1 está no modo pós-manutenção. O Google não lançou mais atualizações do Cloud Composer 1, incluindo novas versões do Airflow, correções de bugs e atualizações de segurança. Recomendamos planejar a migração para o Cloud Composer 2.

Como usar uma conexão personalizada do Airflow

Executar uma tarefa usando uma conexão personalizada do Airflow que você criou anteriormente.

Mais informações

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

Como gerenciar conexões do Airflow

Exemplo de código

Python

Ver no GitHub Feedback

# Set a gcp_conn_id to use a connection that you have created.
task_custom = bigquery.BigQueryInsertJobOperator(
    task_id='task_custom_connection',
    gcp_conn_id='my_gcp_connection',
    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 do navegador do Google Cloud.