Knowledge base

Volver a la descripción general del soporte

Tarea Capturar fuente de datos

Captura una tarea de origen de datos del servidor.

Identificador: fetch_datasource_task

Elementos

  • datasource_id: Contiene el identificador del origen de datos del que se va a recibir una tarea.
    • Tipo: Cadena
  • sheet_revision: Contiene la revisión de la fuente de datos que desea utilizar.
    • Tipo: Largo
  • payload_variable_name: Contiene la carga útil de la tarea capturada que se convertirá y almacenará en el contexto con la clave especificada aquí.
    • Tipo: Cadena
  • task_variable_name: Contiene el objeto de tarea que se almacenará en el contexto con la clave especificada aquí.
    • Tipo: Cadena
  • datasource_task_id: Contiene el identificador de la tarea que se debe capturar.
    • Tipo: Cadena
  • request_new: Indica si se debe capturar una tarea nueva y vacía (alternativa a especificar una datasource_task_id).
    • Tipo: Bool
  • row_count: El número de filas que debe tener una tarea nueva y vacía al solicitar una nueva tarea.
    • Tipo: Largo
  • connection_timeout: Contiene el tiempo de espera en milisegundos.
    • Tipo: Largo

Salida

La etiqueta de evento de este evento es fetch_datasource_task.

  • DE ACUERDO: La tarea de origen de datos se ha recuperado correctamente.
  • ERROR: Se ha producido un error al obtener la tarea. Si el servidor proporciona un mensaje de error, se encontrará en la carga útil. La carga útil está estructurada de la siguiente manera:
    • error
    • error.message
    • error.class
    • error.categoría
    • error.code
  • INTERRUPCIÓN: El servidor no envió una respuesta dentro del tiempo especificado (connection_timeout)

Ejemplo

La tarea fetch datasource se utiliza normalmente junto con una entrada de datasource:

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

Tarea Actualizar fuente de datos

Actualiza una tarea de origen de datos en el servidor.

Identificador: update_datasource_task

Elementos

  • datasource_task_id: Contiene el ID de la tarea que se va a cambiar. Este es el valor de la columna configurada como identificador en la configuración de la fuente de datos.
    • Tipo: Cadena
  • rows: Contiene el objeto de fila que se va a cambiar.
    • Tipo: Objeto
  • payload_variable_name: Contiene la variable en la que se almacena la carga útil de la tarea en el contexto.
    • Tipo: Cadena
  • connection_timeout: Contiene el valor de tiempo de espera en milisegundos.
    • Tipo: Largo

Salida

La etiqueta de evento de este evento es update_datasource_task.

  • Aceptar: La tarea de origen de datos se ha obtenido correctamente.
  • ERROR: Se ha producido un error al obtener la tarea. Si el servidor proporciona un mensaje de error, se encontrará en la carga útil. La carga útil está estructurada de la siguiente manera: error
    • error.message
    • error.class
    • error.categoría
    • error.code
  • TIMEOUT: El servidor no envió una respuesta dentro del tiempo especificado (connection_timeout)

Ejemplo

La tarea de origen de datos se puede utilizar junto con una entrada de origen de datos. Los parámetros dependen  datasource_task_id  payload_variable_namede dónde se guardan los datos. El siguiente ejemplo funcionará con el ejemplo que se muestra en la acción de fetch_datasource_task entrada: 

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

Actualizar el estado de la tarea de la fuente de datos

Actualiza el estado de una tarea de origen de datos.

Identificador: update_datasource_task_status

Elementos

  • datasource_task_id: Contiene el identificador de la tarea que se debe obtener. Este es el valor de la columna configurada como identificador en la configuración de la fuente de datos.
    • Tipo: Cadena
  • status: Contiene la etapa actual de la tarea (por ejemplo, DONE, , CANCELEDPAUSED , o ). IN_PROGRESS
    • Tipo: Cadena
  • connection_timeout: Contiene el valor de tiempo de espera en milisegundos.
    • Tipo: Largo

Salida

La etiqueta de evento de este evento es update_datasource_task_status.

  • Aceptar: La tarea de origen de datos se ha obtenido correctamente.
  • ERROR: Se ha producido un error al obtener la tarea. Si el servidor proporciona un mensaje de error, se encontrará en la carga útil. La carga útil está estructurada de la siguiente manera:error
    • error.message
    • error.class
    • error.categoría
    • error.code
  • TIMEOUT: El servidor no envió una respuesta dentro del tiempo especificado (connection_timeout)

Ejemplo

En este ejemplo se muestra que esto se puede usar junto con una entrada de origen de datos:

<update_datasource_task_status id="cancel_ds_task">
    <param name="datasource_task_id" type="string">?{ context.ds_§{ reemplace 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>