Azkabanがワークフローを作成する方法
How Azkaban Creates Workflow
はじめに:この記事では、ワークフローの基本的なフローを作成します。ここでは、flow2.0を使用してワークフローを作成しますが、flow1.0の後で公式は維持しなくなります
参照:
https://azkaban.readthedocs.io/en/latest/createFlows.html
https://azkaban.readthedocs.io/en/latest/useAzkaban.html
処理する
1、ファイルflow20.projectを作成し、次のコンテンツを追加し、2.0形式で編集するフロースクリプトを宣言します
azkaban-flow-version:2.0
2、依存関係のない最も基本的な単一タスクでワークフローを作成します。ワークフローファイルの名前はbasic.flowで、内容は次のとおりです。
ノード:
-名前:jobA
タイプ:コマンド
構成:
コマンド:echo 'これはエコーされたテキストです。'
3.依存関係のあるワークフローを作成します。ワークフローの名前はbasic.flowで、内容は次のとおりです。
ノード:
-名前:jobC
タイプ:コマンド
依存:
- jobA
--jobB
構成:
コマンド:bash run.bash
-名前:jobA
タイプ:コマンド
構成:
コマンド:echo 'これはjobAテキストです。'
-名前:jobB
タイプ:コマンド
構成:
コマンド:echo 'これはjobBテキストです。
注:jobCはjobA、jobBに依存します
4、flow20.projectとbasic.flowが作成され、これら2つのファイルとタスクが依存するスクリプトファイル(3のjobCのjobCなど)を圧縮する必要があります。run.bashスクリプトを一緒に圧縮する必要があります。 。 )、最終的に圧縮ファイルを生成します(ファイルを直接圧縮するためにここに注意してください。フォルダーをフォルダーに入れないでください)
5、着陸azkabanフロントエンド操作ページ:https:// XXXXX:8888(ポート番号は設定に従って設定する必要があります。通常は8443に設定します。ここでは8888に設定しますが、影響はありません)
6、新しいプロジェクトを作成します
7.以前に作成したワークフロータスクをインポートします
8、ワークフローExcute Flowを実行し、スケジュールを構成します
ここでの構成は30分ごとに実行されます(構成は基本的にliunxのcrontabに似ています)
9、そのような単純なワークフローがあります、あなたはスケジューリングで展開され実行されたワークフローを見ることができます
10、あなたは歴史の中で歴史的な実行を見ることができます
このような単純なワークフローは正常に構成されています。