SubmitQueryJob 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-salesforce-processors-nar
Description¶
Soumet une requête à Salesforce à l’aide de Bulk API 2.0.
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 |
Mode de configuration de ce processeur. Si le mode avancé est utilisé, la requête SOQL doit être fournie et l’état du processeur ne stockera que l’horodatage de la dernière soumission de tâche de requête, quel que soit l’objet interrogé. Si le mode simple est utilisé, 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 tâche de requête pour chaque objet interrogé. |
Incremental Offload |
Indique si le processeur doit effectuer un transfert incrémentiel. Si true, le processeur ne récupérera que les enregistrements modifiés depuis la dernière soumission de 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 à effectuer. Pour effectuer une récupération incrémentielle (c.-à-d. uniquement les éléments ajoutés/modifiés/supprimés depuis la dernière soumission de requête), ce processeur expose deux attributs : ${nowTs} et ${lastJobTimestamp}. Il est possible d’utiliser ces espaces réservés comme suit : 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. |
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. |
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. |
Cas d’utilisation¶
Soumet une requête à Salesforce à l’aide de Bulk API 2.0. |