airflow

0熱

1答えて

毎週月曜日の午前9時にPythonスクリプトのタスクを実行するための正しい構文を確認します。現在、私のスクリプトは、毎週日曜日の午前12時（0 0 * * 0）に送信されるように設定されています。

5熱

2答えて

AirflowのPostgresOperatorとJinjaのテンプレートとSQLを使用した場合

PostgresOperatorでAirflowのテンプレート機能（Jinja2経由）を使用しようとすると、レンダリングすることができませんでした。私は間違ったことをしている可能性はかなり高いですが、問題の可能性についてはかなり失われています。 airflow_home = /home/gregreda/airflow dags_folder = /home/gregreda/airflow/d

4熱

3答えて

エアフローをOracleデータベースに接続する方法

エアフローを使用してoracle dbインスタンス（oracle：thin）への接続を作成しようとしています。は彼らのdocumentationによると、私はポート番号が続く私のホスト名を入力し、SID：ホスト：コネティカットタイプ：は、などの他のフィールドを埋めexample.com:1524/sid Oracle スキーマ：ユーザー名（documentation：スキーマにユーザー名を

4熱

1答えて

エアフロー - 私は空気の流れに新しいですし、私は私のDAGのためのチャートを作成しようとしていますが、私は次のエラーを取得しておく

に失敗クエリをチャート： SELECT dag_id, execution_date, count(*) as ccount FROM task_instance GROUP BY dag_id, execution_date

12熱

4答えて

気流をトリガするDAGが機能していない

エアフローを使用して、コマンドラインから手動でトリガする特定のワークフローを定義しようとしています。私はDAGを作成し、一連のタスクを追加します。 dag = airflow.DAG( "DAG_NAME", start_date=datetime(2015, 1, 1), schedule_interval=None, default_args=args)

15熱

2答えて

エアフローのDAG間の依存関係を設定するにはどうすればよいですか？

私はAirflowを使用してバッチジョブをスケジュールしています。毎晩1つのDAG（A）と毎月1回実行する別のDAG（B）があります。 Bは成功裏に完了したAに依存する。ただし、Bの実行には時間がかかります。したがって、SLAレポートをより良くするために、別のDAGに保存したいと考えています。 DAGの実行をDAG Aの実行に依存するようにするにはどうすればよいですか？

1熱

1答えて

ランダムな時間にDAGを起動する方法

気流スケジューラによって起動され、毎日深夜0時に実行されるDAGがあります。私は毎日の開始時間をダイナミックに変更したい、ある日は午前1時に開始し、翌日は00:16などに変更したい。これを行うためのエアフローの設定はありますか？私は何ができないのでしょうか？

2熱

1答えて

オペレータの実行後にエアフローが発生する

エアフローを設定し、いくつかの演算子を呼び出すDagsとsubDagを作成しました。私の問題は、オペレータがジョブを実行して終了したときに、結果をいくつかのPython構造体に戻したいということです。例えば： File1.py ... ... sub_dag_one=SubDagOperator(subdag=subdag_accessHive( PARENT_DAG_NA

0熱

1答えて

気流のジョブ状況

3つのタスクでDAGを作成しました。タスクの1つが失敗したので、そのジョブは失敗として表示されます。しかし、私は以前の仕事のバックフィルをします。今すぐ成功しましたが、JOBのステータスは変わりませんが、個々のタスクが成功したにもかかわらずまだ失敗していることを示しています。私は何かを逃していますか？

6熱

2答えて

エアフロー：エアフロー

にDAGのためのcrontabの時間を変更するには、私は3:00に毎日実行されているDAGは、それは過去数週間のために[OK]を走ってきました。私は7:00になりまし実行する日付を更新したが、どうやら、最後の2日間、それは実行されませんでした。ステータスが「実行中」（緑色）の2日間のタスクが表示されますが、コマンドはトリガーされません。は、1つのDAGの時間を実行しているドを変更するにはより多