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¶

bulk, job, preview, query, 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	The configuration mode for configuring this processor. If using advanced mode, the SOQL query has to be provided and the processor “s state will only store the timestamp of the last query job submission regardless of the object queried. If using simple mode, the object name and the fields to be queried have to be provided and the processor’s state will store the timestamp of the last query job submission for each object queried.
Incremental Offload	Whether the processor should perform incremental offload. If true, the processor will only fetch the records that have been modified since the last query job submission by using a WHERE clause on the SystemModstamp field.
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	The query to be performed. In order to perform incremental retrieval (ie. only the added/modified/deleted elements since the last submission of the query are retrieved), this processor exposes two attributes: ${nowTs} and ${lastJobTimestamp}. It is possible to use those placeholders like SELECT Id FROM Account 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	An incoming FlowFile is routed to this relationship when a previous job for the same object is still 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.