知識ベース

サポート概要に戻る

データソースのフェッチタスク

サーバーからデータ・ソース・タスクをフェッチします。

識別子: fetch_datasource_task

元素

  • datasource_id: タスクを受信するデータ ソースの ID が含まれます。
    • タイプ: 文字列
  • sheet_revision: 使用するデータソースのリビジョンが含まれます。
    • タイプ: ロング
  • payload_variable_name: ここで指定したキーで変換され、コンテキストに格納されるフェッチされたタスクのペイロードが含まれます。
    • タイプ: 文字列
  • task_variable_name: ここで指定したキーを持つコンテキストに格納されるタスクオブジェクトが含まれます。
    • タイプ: 文字列
  • datasource_task_id: フェッチするタスクの ID が含まれます。
    • タイプ: 文字列
  • request_new: 新しい空のタスクをフェッチするかどうかを示します (datasource_task_idを指定する代わりに)。
    • 種類： ブール
  • row_count: 新しいタスクを要求するときに、新しい空のタスクに必要な行数。
    • タイプ: ロング
  • connection_timeout: タイムアウトをミリ秒単位で格納します。
    • タイプ: ロング

アウトプット

このイベントのイベントタグは です fetch_datasource_task。

  • わかりました： データ・ソース・タスクが正常にフェッチされました。
  • エラー： タスクのフェッチ中にエラーが発生しました。サーバーがエラーメッセージを提供する場合、そのメッセージはペイロードで見つかります。ペイロードは次のように構成されています。
    • エラー
    • error.message (エラー.メッセージ)
    • error.class (エラー.クラス)
    • error.category (エラー.カテゴリ)
    • エラーコード
  • タイムアウト： サーバーは指定された時間内に応答を送信しませんでした (connection_timeout)

例

フェッチデータソースタスクは、通常、データソース入力と 組み合わせて使用されます。

<fetch_datasource_task id="fetch_datasource_task">
    <param name="datasource_id" type="string">§{ configuration.datasource.value.id }§</param>
    <param name="sheet_revision" type="string">§{ configuration.datasource.value.selectedRevision }§</param><
    param name="payload_variable_name" type="string">ds_§{ replaceconfiguration.datasource.value.id '-' ''  }§</param>
    <param name="task_variable_name" type="string">ds_§{ replace configuration.datasource.value.id '-' '' }§_task</param>
    <param name="request_next" type="bool">§{ #if configuration.enable_scan.value}§false§{else}§true§{/if}§</param>
    <param name="request_new" type="bool">§{ #if configuration.request_new.value}§true§{else}§false§{/if}§</param>
    <param name="row_count" type="long">§{ configuration.row_count.value }§</param><
    param name="datasource_task_id" type="string">#{task_id}</param>
    <param name="connection_timeout" type="string">?{§{configuration.timeout.value}§*1000}?</param>
</fetch_datasource_task>

データソースの更新タスク

サーバー上のデータ・ソース・タスクを更新します。

識別子: update_datasource_task

元素

  • datasource_task_id: 変更するタスクの ID が含まれます。これは、データソース設定で識別子として構成された列の値です。
    • タイプ: 文字列
  • rows: 変更する行オブジェクトが含まれます。
    • タイプ: オブジェクト
  • payload_variable_name: タスクのペイロードがコンテキストに格納される変数が含まれます。
    • タイプ: 文字列
  • connection_timeout: タイムアウト値をミリ秒単位で含みます。
    • タイプ: ロング

アウトプット

このイベントのイベントタグは です update_datasource_task。

  • OK: データソースタスクが正常にフェッチされました。
  • エラー： タスクのフェッチ中にエラーが発生しました。サーバーがエラーメッセージを提供する場合、そのメッセージはペイロードで見つかります。ペイロードは次のように構成されています。 error
    • error.message (エラー.メッセージ)
    • error.class (エラー.クラス)
    • error.category (エラー.カテゴリ)
    • エラーコード
  • タイムアウト: サーバーは指定された時間内に応答を送信しませんでした()connection_timeout

例

データソースタスクは、データソース入力と 組み合わせて使用できます。の datasource_task_id パラメータは、 payload_variable_name データの保存場所によって異なります。以下の例は、入力 アクションに示されている  fetch_datasource_task例で動作します。

<update_datasource_task id="update_ds_with_row">
    <param name="datasource_task_id" type="string">?{context.ds_§{ replace validation.datasource.value.id '-' '' }§_task.id}?</param>
    <param name="rows">#{current_row}</param>
    <param name="payload_variable_name">ds_§{ replace validation.datasource.value.id '-' ''  }§</param><
/update_datasource_task>

データソースタスクステータスの更新

データ・ソース・タスクのステータスを更新します。

識別子: update_datasource_task_status

元素

  • datasource_task_id: フェッチするタスクの ID が含まれます。これは、データソース設定で識別子として構成された列の値です。
    • タイプ: 文字列
  • status: タスクの現在のステージ (DONE 例: 、CANCELED 、PAUSED 、) IN_PROGRESSが含まれます。
    • タイプ: 文字列
  • connection_timeout: タイムアウト値をミリ秒単位で含みます。
    • タイプ: ロング

アウトプット

このイベントのイベント タグは update_datasource_task_statusです。

  • OK: データソースタスクが正常にフェッチされました。
  • エラー： タスクのフェッチ中にエラーが発生しました。サーバーがエラーメッセージを提供する場合、そのメッセージはペイロードで見つかります。ペイロードは次のように構成されています。
    • error.message (エラー.メッセージ)
    • error.class (エラー.クラス)
    • error.category (エラー.カテゴリ)
    • エラーコード
  • タイムアウト: サーバーは指定された時間内に応答を送信しませんでした()connection_timeout

例

この例は、これをデータソース入力と 組み合わせて使用できることを示しています。

<update_datasource_task_status id="cancel_ds_task">
    <param name="datasource_task_id" type="string">?{context.ds_§{ replace validation.datasource.value.id '-' '' }§_task.id}?</param>
    <param name="status" type="string">CANCELED</param>
    <param name="connection_timeout" type="string">10000</param><
/update_datasource_task_status>