RESTクライアントAPIを使用
- Last Updated: April 5, 2026
- 3 minute read
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"]}
Parameters
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を追加します。
See Also
関連するタスク
関連する情報