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, Abfrage, 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	Der Konfigurationsmodus zum Konfigurieren dieses Prozessors. Wenn Sie den erweiterten Modus verwenden, muss die SOQL-Abfrage angegeben werden, und der Status des Prozessors speichert nur den Zeitstempel der letzten Übermittlung des Abfragejobs, unabhängig vom abgefragten Objekt. Wenn Sie den einfachen Modus verwenden, müssen der Objektname und die abzufragenden Felder angegeben werden, und der Zustand des Prozessors speichert den Zeitstempel der letzten Übermittlung des Abfragejobs für jedes abgefragte Objekt.
Incremental Offload	Gibt an, ob der Prozessor eine inkrementelle Auslagerung ausführen soll. Bei „true“ ruft der Prozessor nur die Datensätze ab, die seit der letzten Übermittlung des Abfragejobs geändert wurden, mithilfe einer WHERE-Klausel für das Feld SystemModstamp.
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	Die auszuführende Abfrage. Um einen inkrementellen Abruf durchzuführen (d. h. nur die seit der letzten Abfrage hinzugefügten/geänderten Elemente werden abgerufen), stellt dieser Prozessor zwei Attribute zur Verfügung: ${nowTs} und ${lastJobTimestamp}. Es ist möglich, Platzhalter wie SELECT ID FROM Account WHERE SystemModstamp > ${lastJobTimestamp} AND SystemModstamp <= ${nowTs} zu verwenden.
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	Ein eingehendes FlowFile wird an diese Beziehung weitergeleitet, wenn ein vorheriger Job für dasselbe Objekt noch immer IN_PROGRESS ist.
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.