Data Integration

<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_§{ replace 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>
    <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

Updates a datasource task on the server.

Identifier: update_datasource_task

Elements

• datasource_task_id:Contains the ID of the task to be changed. This is the value of the column configured as the identifier in the datasource settings.
  • Type: String
• rows:Contains the row object to be changed.
  • Type: Object
• payload_variable_name:Contains the variable in which the payload of the task is stored in the context.
  • Type: String
• connection_timeout:Contains the timeout value in milliseconds.
  • Type: Long

Output

The event tag of this event is update_datasource_task.

• OK: The datasource task has been successfully fetched.
• ERROR: There was an error while fetching the task. If the server provides an error message, it will be found in the payload. The payload is structured as follows: error
  • error.message
  • error.class
  • error.category
  • error.code
• TIMEOUT: The server did not send a response within the specified time (connection_timeout)

Example

The datasource task can be used in conjunction with a datasource input. The parameters for datasource_task_id and payload_variable_name depend on where your data is saved. The example below will work with the example shown in the fetch_datasource_task input action:

<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 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>