O Cloud Composer 1 está no modo pós-manutenção. O Google não lança mais atualizações para o 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.

Use o BashOperator para executar o comando bq do BigQuery

Usar o BashOperator em um DAG do Apache Airflow para chamar o comando bq do BigQuery.

Mais informações

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

Como escrever DAGs (fluxos de trabalho)

Exemplo de código

Python

Ver no GitHub Feedback

from airflow.operators import bash
    # Create BigQuery output dataset.
    make_bq_dataset = bash.BashOperator(
        task_id='make_bq_dataset',
        # Executing 'bq' command requires Google Cloud SDK which comes
        # preinstalled in Cloud Composer.
        bash_command=f'bq ls {bq_dataset_name} || bq mk {bq_dataset_name}')

A seguir

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