SubmitQueryJob 2025.10.2.19¶

Bundle¶

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

Beschreibung¶

Übermitteln eines Abfrage-Jobs an Salesforce unter Verwendung der Bulk API 2.0 Im SIMPLE-Modus wird der Status pro Objekt (previousLast/currentLast und Status) im konfigurierten Controller-Service gespeichert. Im ADVANCED-Modus wird ein einziger „last“-Zeitstempel auf Prozessorebene gespeichert, um inkrementelle Abfragen über Objekte hinweg zu unterstützen.

Tags¶

bulk, job, preview, query, salesforce

Eingabeanforderung¶

ALLOWED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
Column Delimiter	Das Spaltentrennzeichen, das für CSV-Jobdaten verwendet wird.
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	Das Zeilenende, das für CSV-Jobdaten verwendet wird und das Ende einer Datenzeile markiert.
Objektfelder	Durch Kommas getrennte Liste mit den Namen der Felder, die für das angegebene Objekt abgefragt werden sollen.
Objektname	Der Name des Objekts, das abgefragt werden soll.
Operation	Die Typ der zu übermittelnden Abfrage.
Abfrage	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}.
Ergebnisformat	Das Formatfür die Ergebnisse zu verwendende Format. Derzeit wird nur der Wert CSV unterstützt.
Salesforce Bulk Job State Service	Controller-Service zum Speichern des Bulk Jobs-Status pro Objekttyp (verwendet in SIMPLE-Modus). Im ADVANCED-Modus speichert der Prozessor einen einzigen „last“ Zeitstempel im Prozessorstatus.
Salesforce Client	Salesforce-Client für die Interaktion mit den APIs

Statusmanagement¶

Bereiche	Beschreibung
CLUSTER	Wenn im Abfragefeld Platzhalter für die inkrementelle Abfrage verwendet werden, wird der Zeitstempel der letzten Übermittlung des Abfragejobss minus 30 Sekunden im Status gespeichert.

Beziehungen¶

Name	Beschreibung
comms.failure	Ein eingehendes FlowFile wird an diese Beziehung weitergeleitet wenn der Abfragejob nicht übermittelt werden konnte, der Vorgang aber möglicherweise erneut versucht wird.
failure	Ein eingehendes FlowFile wird an diese Beziehung weitergeleitet, wenn der Abfragejob nicht übermittelt werden konnte.
in.progress	An incoming FlowFile is routed to this relationship when a previous job for the same object is still IN_PROGRESS
success	Wenn ein Abfragejob erfolgreich übermittelt wird, wird ein FlowFile an diese Beziehung weitergeleitet.

Schreibt Attribute¶

Name	Beschreibung
jobId	Die eindeutige ID für diesen Job.
operationType	Der Typ der Abfrage.
objectType	Der Objekttyp, der abgefragt wird.
createdById	Die ID des Benutzers, der den Auftrag erstellt hat.
createdDate	Das UTC Datum und die Uhrzeit, zu denen der Job erstellt wurde.
systemModstamp	Das UTC-Datum und die Uhrzeit, zu der die API die Jobinformationen zuletzt aktualisiert hat.
jobState	Der aktuelle Stand der Bearbeitung des Jobs.
concurrencyMode	Wie die Anfrage bearbeitet wird.
contentType	Das Formatfür die Ergebnisse zu verwendende Format.
apiVersion	Die API-Version, in der der Job erstellt wurde.
lineEnding	Das Zeilenende, das für CSV-Jobdaten verwendet wird und das Ende einer Datenzeile markiert.
columnDelimiter	Das Spaltentrennzeichen, das für CSV-Jobdaten verwendet wird.
nowTs	Obere Grenze des in der WHERE-Klausel verwendeten Zeitbereichs, um den Abfrage-Job zu erstellen.
lastJobTimestamp	Untere Grenze des in der WHERE-Klausel verwendeten Zeitbereichs, um den Abfrage-Job zu erstellen.

Anwendungsfälle¶

Übermittelt einen Abfragejob an Salesforce unter Verwendung der Bulk-API 2.0.