RESTクライアントAPIによるフローの実行
フローが実行されると、データハブでは以下を実行します。
- コレクタを呼び出して、処理するレコードのIDのリストを取得します。
- リストをバッチに分割します。
- このフローのmain.[xqy|sjs]を実行するカスタムREST拡張機能を呼び出します。
MarkLogicデータハブでは、以下の指定が可能なRESTクライアントAPI拡張機能runFlowを提供しています。
- 処理する個々のレコード
- 実行するステップ1つ
mlRunFlow (POST)
指定したレコードを処理するために、フロー内の単一ステップを実行するRESTクライアントAPI拡張機能です。
POST /v1/resources/mlRunFlow?rs:job-id=YourJobID&rs:flow-name=YourFlowName&rs:step=1&database=YourSourceDatabase&rs:target-database=YourTargetDatabase&rs:options={"uris":["comma-separated","uris","of","records","to","process"]}
- rs:job-id
- このフローの実行に対応付けられた一意のジョブID。このオプションは、フローの実行がより大きなプロセスの一部である場合に使用できます(例えば、NiFiが独自のジョブ/プロセスIDによりオーケストレーションしたプロセスなど)。既存のデータハブのジョブIDと同じにすることはできません。指定していない場合は、一意のデータハブジョブIDが割り当てられます。
- rs:flow-name
- フローの名前です。
- rs:step
- 実行するステップのシーケンス番号。特定のステップを複数実行するには、オーケストレーションツールを使用して、ステップごとに1つのrunFlowリクエストを送信します。
- database
- ソースデータを含むデータベース(例:data-hub-STAGING)。
- rs:target-database
- 処理済みのデータを保存するデータベース(例:data-hub-FINAL)。
- rs:options
- フローに渡す追加オプションを含むJSONオブジェクト。
- 処理するレコードのリストを指定するには、処理するレコードのURIの配列を値として含むキーurisを追加します。