Tâche d’extraction de la source de données
Récupère une tâche de source de données à partir du serveur.
Identifiant : fetch_datasource_task
Éléments
- datasource_id : Contient l’ID de la source de données à partir de laquelle recevoir une tâche.
- Type : Chaîne
- sheet_revision : Contient la révision de la source de données que vous souhaitez utiliser.
- Type : Long
- payload_variable_name : Contient la charge utile de la tâche récupérée qui sera convertie et stockée dans le contexte avec la clé spécifiée ici.
- Type : Chaîne
- task_variable_name : Contient l’objet de tâche qui sera stocké dans le contexte avec la clé spécifiée ici.
- Type : Chaîne
- datasource_task_id : Contient l’ID de la tâche qui doit être récupérée.
- Type : Chaîne
- request_new : Indique si une nouvelle tâche vide doit être récupérée (alternative à la spécification d’un datasource_task_id).
- Type: Bool
- row_count : Nombre de lignes qu’une nouvelle tâche vide doit avoir lors de la demande d’une nouvelle tâche.
- Type : Long
- connection_timeout : Contient le délai d’expiration en millisecondes.
- Type : Long
Sortie
La balise d’événement de cet événement est fetch_datasource_task.
- D’ACCORD: La tâche de source de données a été récupérée avec succès.
- ERREUR: Une erreur s’est produite lors de l’extraction de la tâche. Si le serveur fournit un message d’erreur, il se trouvera dans la charge utile. La charge utile est structurée comme suit :
- erreur
- message_erreur
- classe.erreur
- error.category (en anglais seulement)
- code.erreur
- TIMEOUT: Le serveur n’a pas envoyé de réponse dans le délai spécifié (
connection_timeout)
Exemple
La tâche fetch datasource est généralement utilisée en conjonction avec une entrée de source de données :
<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>
Mettre à jour la tâche de source de données
Met à jour une tâche de source de données sur le serveur.
Identifiant : update_datasource_task
Éléments
- datasource_task_id : Contient l’ID de la tâche à modifier. Il s’agit de la valeur de la colonne configurée en tant qu’identificateur dans les paramètres de la source de données.
- Type : Chaîne
- rows : contient l’objet row à modifier.
- Type : Objet
- payload_variable_name : contient la variable dans laquelle la charge utile de la tâche est stockée dans le contexte.
- Type : Chaîne
- connection_timeout : contient la valeur du délai d’expiration en millisecondes.
- Type : Long
Sortie
La balise d’événement de cet événement est update_datasource_task.
- OK : la tâche de source de données a été récupérée avec succès.
- ERREUR: Une erreur s’est produite lors de l’extraction de la tâche. Si le serveur fournit un message d’erreur, il se trouvera dans la charge utile. La charge utile est structurée comme suit : erreur
- message_erreur
- classe.erreur
- error.category (en anglais seulement)
- code.erreur
- TIMEOUT : Le serveur n’a pas envoyé de réponse dans le délai spécifié (
connection_timeout)
Exemple
La tâche de source de données peut être utilisée conjointement avec une entrée de source de données. Les paramètres de datasource_task_id et payload_variable_name dépendent de l’emplacement d’enregistrement de vos données. L’exemple ci-dessous fonctionnera avec l’exemple affiché dans l’action d’entrée fetch_datasource_task :
<update_datasource_task id="update_ds_with_row">
<param name="datasource_task_id » type="string"> ?{ context.ds_§{ remplacer validation.datasource.value.id '-' '' }§_task.id} ?</param>
<param name="rows">#{current_row}</param>
<param name="payload_variable_name">ds_§{ remplacer validation.datasource.value.id '-' '' }§</param>
</update_datasource_task>
Mettre à jour l’état de la tâche de source de données
Met à jour l’état d’une tâche de source de données.
Identifiant : update_datasource_task_status
Éléments
- datasource_task_id : contient l’ID de la tâche qui doit être récupérée. Il s’agit de la valeur de la colonne configurée en tant qu’identificateur dans les paramètres de la source de données.
- Type : Chaîne
- status : contient l’étape actuelle de la tâche (par exemple,
DONE,CANCELED,PAUSEDou ).IN_PROGRESS- Type : Chaîne
- connection_timeout : contient la valeur du délai d’expiration en millisecondes.
- Type : Long
Sortie
La balise d’événement de cet événement est update_datasource_task_status.
- OK : la tâche de source de données a été récupérée avec succès.
- ERREUR: Une erreur s’est produite lors de l’extraction de la tâche. Si le serveur fournit un message d’erreur, il se trouvera dans la charge utile. La charge utile est structurée comme suit :error
- message_erreur
- classe.erreur
- error.category (en anglais seulement)
- code.erreur
- TIMEOUT : Le serveur n’a pas envoyé de réponse dans le délai spécifié (
connection_timeout)
Exemple
Cet exemple montre que cela peut être utilisé en conjonction avec une entrée de source de données :
<update_datasource_task_status id="cancel_ds_task">
<param name="datasource_task_id » type="string"> ?{ context.ds_§{ remplacer 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>