知识库

返回支持概述

获取数据源任务

从服务器获取数据源任务。

标识符： 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
    • 错误类别
    • 错误代码
  • 超时： 服务器未在指定时间（connection_timeout） 内发送响应

例

提取数据源任务通常与 数据源输入结合使用：

<fetch_datasource_task id=“fetch_datasource_task”>
    <参数名称=“datasource_id” type=“字符串”>§{ configuration.datasource.value.id }§</param>
    <参数名称=“sheet_revision” type=“字符串”>§{ configuration.datasource.value.selectedRevision }§</param>
    <参数名称=“payload_variable_name” type=“字符串”>ds_§{ 替换configuration.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>
    <参数名称=“request_new” type=“bool”>§{ #if configuration.request_new.value}§true§{else}§false§{/if}§</param>
    <参数名称=“row_count” type=“long”>§{ configuration.row_count.value }§</param>
    <参数名称=“datasource_task_id” type=“字符串”>#{task_id}</参数>
    <参数名称=“connection_timeout” type=“字符串”>？{§{configuration.timeout.value}§*1000}？</param>
</fetch_datasource_task>

更新数据源任务

更新服务器上的数据源任务。

标识符： update_datasource_task

元素

  • datasource_task_id： 包含要更改的任务的 ID。这是在数据源设置中配置为标识符的列的值。
    • 类型： 字符串
  • rows： 包含要更改的行对象。
    • 类型： 对象
  • payload_variable_name： 包含任务的有效负载存储在上下文中的变量。
    • 类型： 字符串
  • connection_timeout： 包含超时值（以毫秒为单位）。
    • 类型： 长

输出

此事件的事件标记是 update_datasource_task。

  • 确定： 数据源任务已成功获取。
  • 错误： 获取任务时出错。如果服务器提供错误消息，则会在有效负载中找到它。有效负载的结构如下： error
    • error.message
    • error.class
    • 错误类别
    • 错误代码
  • TIMEOUT： 服务器未在指定时间内发送响应 （connection_timeout）

例

数据源任务可以与 数据源输入结合使用。和 payload_variable_name 的参数 datasource_task_id 取决于数据的保存位置。以下示例将适用于输入 操作中显示的  fetch_datasource_task示例：

<update_datasource_task id=“update_ds_with_row”>
    <参数名称=“datasource_task_id” type=“string”>？{context.ds_§{ 替换 validation.datasource.value.id '-' '' }§_task.id}？</param>
    <param name=“rows”>#{current_row}</param>
    <param name=“payload_variable_name”>ds_§{ 替换 validation.datasource.value.id '-' ''  }§</param>
</update_datasource_task>

更新数据源任务状态

更新数据源任务的状态。

标识符： update_datasource_task_status

元素

  • datasource_task_id： 包含应提取的任务的 ID。这是在数据源设置中配置为标识符的列的值。
    • 类型： 字符串
  • status： 包含任务的当前阶段（例如， DONE、、 IN_PROGRESS CANCELEDPAUSED 或）。
    • 类型： 字符串
  • connection_timeout： 包含超时值（以毫秒为单位）。
    • 类型： 长

输出

此事件的事件标签是 update_datasource_task_status。

  • 确定： 数据源任务已成功获取。
  • 错误： 获取任务时出错。如果服务器提供错误消息，则会在有效负载中找到它。有效负载的结构如下：error
    • error.message
    • error.class
    • 错误类别
    • 错误代码
  • TIMEOUT： 服务器未在指定时间内发送响应 （connection_timeout）

例

此示例演示这可以与 数据源输入结合使用：

<update_datasource_task_status id=“cancel_ds_task”>
    <参数名称=“datasource_task_id” type=“string”>？{context.ds_§{ 替换 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>