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、あなたは歴史の中で歴史的な実行を見ることができます

このような単純なワークフローは正常に構成されています。