SubmitQueryJob 2025.10.2.19¶

Bundle¶

com.snowflake.openflow.runtime | runtime-salesforce-processors-nar

Description¶

Soumet une tâche de requête à Salesforce en utilisant l’API 2.0 groupée. En mode SIMPLE, l’état par objet (previousLast/currentLast et status) est stocké dans le service de contrôleur configuré. En mode ADVANCED, un seul horodatage « last » est stocké au niveau du processeur pour prendre en charge les requêtes incrémentielles inter-objets.

Balises¶

groupé, tâche, prévisualisation, requête, salesforce

Exigences en matière d’entrées¶

ALLOWED

Prend en charge les propriétés dynamiques sensibles¶

false

Propriétés¶

Propriété	Description
Column Delimiter	Le délimiteur de colonne utilisé pour les données de tâche CSV.
Configuration Mode	Le mode de configuration pour la configuration de ce processeur. Si vous utilisez le mode avancé, la requête SOQL doit être fournie et l’état du processeur ne stockera que l’horodatage de la dernière soumission de la tâche de requête, quel que soit l’objet interrogé. Si vous utilisez le mode simple, le nom de l’objet et les champs à interroger doivent être fournis et l’état du processeur stockera l’horodatage de la dernière soumission de la tâche de requête pour chaque objet interrogé.
Incremental Offload	Si le processeur doit effectuer un déchargement incrémentiel. Si « true », le processeur ne récupérera que les enregistrements qui ont été modifiés depuis la dernière soumission de la tâche de requête en utilisant une clause WHERE sur le champ SystemModstamp.
Line Ending	La fin de ligne utilisée pour les données de tâche CSV, marquant la fin d’une ligne de données.
Object Fields	Liste, séparée par des virgules, des noms de champs à interroger pour l’objet spécifié.
Nom d’objet	Le nom de l’objet à interroger.
Fonctionnement	Le type de requête à soumettre.
Requête	La requête à exécuter. Afin d’exécuter une récupération incrémentielle (c’est-à-dire que seuls les éléments ajoutés/modifiés/supprimés depuis la dernière soumission de la requête sont récupérés), ce processeur expose deux attributs : ${nowTs} et ${lastJobTimestamp}. Il est possible d’utiliser ces espaces réservés comme SELECT ID FROM Compte WHERE SystemModstamp > ${lastJobTimestamp} AND SystemModstamp <= ${nowTs}.
Result Format	Le format à utiliser pour les résultats. Actuellement, la seule valeur prise en charge est CSV.
Service d’état des tâches groupées Salesforce	Service de contrôleur permettant de stocker l’état des tâches groupées par type d’objet (utilisé en mode SIMPLE). En mode ADVANCED, le processeur stocke un seul horodatage « last » dans son état.
Salesforce Client	Le client Salesforce qui doit interagir avec les API

Gestion de l’État¶

Champs d’application	Description
CLUSTER	En cas d’utilisation des espaces réservés pour la récupération incrémentielle dans le champ de requête, l’horodatage de la dernière soumission de tâche de requête moins 30 secondes sera stocké dans l’état.

Relations¶

Nom	Description
comms.failure	Un FlowFile entrant est routé vers cette relation si la tâche de requête n’a pas pu être soumise, mais que l’opération pourrait être réessayée.
failure	Un FlowFile entrant est routé vers cette relation si la tâche de requête n’a pas pu être soumise.
in.progress	Un FlowFile entrant est routé vers cette relation lorsqu’une tâche précédente pour le même objet est encore IN_PROGRESS
success	Lorsqu’une tâche de requête est soumise avec succès, un FlowFile est routé vers cette relation.

Écrit les attributs¶

Nom	Description
jobId	L’identifiant unique ID de cette tâche.
operationType	Le type de requête.
objectType	Le type d’objet faisant l’objet de la requête.
createdById	L’ID de l’utilisateur qui a créé le travail.
createdDate	La date et l’heure UTC de création de la tâche.
systemModstamp	La date et l’heure UTC de la dernière mise à jour des informations sur la tâche par l’API.
jobState	L’état actuel du traitement de la tâche.
concurrencyMode	Mode de traitement de la requête.
contentType	Le format à utiliser pour les résultats.
apiVersion	La version API dans laquelle la tâche a été créée.
lineEnding	La fin de ligne utilisée pour les données de tâche CSV, marquant la fin d’une ligne de données.
columnDelimiter	Le délimiteur de colonne utilisé pour les données de tâche CSV.
nowTs	Limite supérieure de la plage de temps utilisée dans la clause WHERE pour construire la tâche de requête.
lastJobTimestamp	Limite inférieure de la plage de temps utilisée dans la clause WHERE pour construire la tâche de requête.

Cas d’utilisation¶

Soumet une requête à Salesforce à l’aide de Bulk API 2.0.