SubmitQueryJob 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-salesforce-processors-nar
Beschreibung¶
Übermittelt einen Abfragejob an Salesforce unter Verwendung der Bulk-API 2.0.
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 unabhängig vom abgefragten Objekt nur den Zeitstempel des letzten Abfragejobs. Im einfachen Modus müssen der Objektname und die abzufragenden Felder angegeben werden, und der Prozessor speichert für jedes abgefragte Objekt den Zeitstempel der letzten Übermittlung eines Abfrageauftrags. |
Incremental Offload |
Ob der Prozessor ein inkrementelles Offload durchführen soll. Wenn „true“, ruft der Prozessor nur die Datensätze ab, die seit der letzten Abfrage geändert wurden, indem er eine WHERE-Klausel für das Feld SystemModstamp verwendet. |
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 durchzuführnede Abfrage. Um eine inkrementelle Abfrage durchzuführen (d. h. es werden nur die seit der letzten Übermittlung der Abfrage hinzugefügten/geänderten/gelöschten Elemente abgerufen), stellt dieser Prozessor zwei Attribute zur Verfügung: ${nowTs} und ${lastJobTimestamp}. Es ist möglich, diese Platzhalter wie SELECT ID FROM Konto 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 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. |
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. |
Anwendungsfälle¶
Übermittelt einen Abfragejob an Salesforce unter Verwendung der Bulk-API 2.0. |