複数の BashOperator

Airflow の DAG には、多くのオペレーターを含めることができ、それぞれが定義されたタスクを実行します。

すでに 1 つのスクリプトを Airflow のタスクとして実装できたので、個別のスクリプトを本格的な Airflow の DAG に移行し続けることにしました。これからワークフローにさらにコンポーネントを追加します。前の演習で使った cleanup.sh に加えて、consolidate_data.sh と push_data.sh の 2 つのスクリプトがあります。これらはデータをさらに処理し、最終的な場所へコピーします。

DAG analytics_dag はすでに定義されています（つまり、with DAG(...) 文を追加する必要はありません）。また、cleanup タスクも定義済みです。BashOperator はすでにインポートされています。