RESTクライアントAPIの使用

Save PDF

Last Updated: April 5, 2026
3 minute read

RESTクライアントAPIによるFlowの実行

Flowを実行すると、データハブでは以下を実行します。

コレクタを呼び出して、処理するレコードのIDのリストを取得します。
リストをバッチに分割します。
Flowのmain.[xqy|sjs]を実行するカスタムREST拡張機能を呼び出します。

MarkLogicデータハブでは、以下の指定が可能なRESTクライアントAPI拡張機能**runFlow**を提供しています。

処理する個々のレコード
実行する単一ステップ

ml:runFlow

指定したレコードを処理するためのFlow全体、またはFlow内の単一ステップを実行するRESTクライアントAPI拡張機能。


          POST /v1/resources/ml:runFlow?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

Flowの実行に関連付けられた一意のジョブID。このオプションは、大規模なプロセスの一環としてFlowが実行される場合に使用できます（例えば、NiFiが独自のジョブ/プロセスIDによりオーケストレーションされたプロセスなど）。既存のデータハブのジョブIDと同じにすることはできません。指定していない場合は、一意のデータハブジョブIDが割り当てられます。

rs:flow-name

Flowの名前。

rs:step

実行するステップのシーケンス番号。複数の特定のステップを実行するには、オーケストレーションツールを使用して、ステップごとに1つの**runFlow**リクエストを送信します。

データベース

ソースデータを含むデータベース（例：data-hub-STAGING ）。

rs:target-database

処理済みのデータを保存するデータベース（例：data-hub-FINAL）。

rs:options

Flowに渡す追加オプションを含むJSONオブジェクト。

処理するレコードのリストを指定するには、処理するレコードのURIの配列を値として含むキーurisを追加します。

MarkLogic Data Hub