QuerySalesforceObject 2025.10.2.19¶

Bundle¶

org.apache.nifi | nifi-salesforce-nar

Beschreibung¶

Ruft Datensätze aus einem Salesforce sObject ab. Benutzer können beliebige Filterbedingungen hinzufügen, indem sie die Eigenschaft „Custom WHERE Condition“ einstellen. Der Prozessor kann auch eine kundenspezifische Abfrage ausführen, obwohl die Verarbeitung von Datensätzen in diesem Fall nicht unterstützt wird. Unterstützt den inkrementellen Abruf: Benutzer können ein Feld in der Eigenschaft „Age Feld“ definieren, das verwendet wird, um zu bestimmen, wann der Datensatz erstellt wurde. Wenn diese Eigenschaft eingestellt ist, ruft der Prozessor neue Datensätze ab. Inkrementelles Laden und datensatzbasierte Verarbeitung werden nur in eigenschaftsbasierten Abfragen unterstützt. Es ist auch möglich, einen anfänglichen Grenzwert für das Alter zu definieren, der alle älteren Datensätze selbst für den ersten Durchlauf herausfiltert. Im Falle einer eigenschaftsbasierten Abfrage (Property Based Query) sollte dieser Prozessor nur auf dem Primärknoten ausgeführt werden. Das FlowFile-Attribut „record.count“ gibt an, wie viele Datensätze abgerufen und in die Ausgabe geschrieben wurden. Der Prozessor kann ein optionales Eingabe-FlowFile akzeptieren und auf FlowFile-Attribute in der Abfrage verweisen. Wenn „Include Deleted Records“ den Wert „true“ hat, nimmt der Prozessor gelöschte Datensätze (Soft-Deletes) mithilfe der „queryAll“-API in die Ergebnisse auf. Das Feld „IsDeleted“ wird bei der Abfrage gelöschter Datensätze automatisch in die Ergebnisse aufgenommen.

Tags¶

query, salesforce, sobject, soql

Eingabeanforderung¶

ALLOWED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
age-delay	Der Endzeitstempel des Zeitfensters wird um den in dieser Eigenschaft konfigurierten Wert nach vorne verschoben. Bei einem Eigenschaftswert von 10 Sekunden würde zum Beispiel ein Endzeitstempel von 12:30:45 in 12:30:35 geändert werden.
age-field	Der Name eines TIMESTAMP-Feldes, das verwendet wird, um Datensätze mit einem begrenzten Zeitfenster zu filtern. Der Prozessor gibt nur die Datensätze zurück, deren Zeitstempelwert neuer ist als der Zeitstempel, der nach der letzten Prozessorausführung aufgezeichnet wurde.
create-zero-record-files	Gibt an, ob ein FlowFile erstellt werden soll, wenn die Salesforce REST-API keine Datensätze zurückgibt.
custom-soql-query	Geben Sie die auszuführende SOQL-Abfrage an.
custom-where-condition	Ein benutzerdefinierter Ausdruck, der in der WHERE-Klausel der Abfrage hinzugefügt wird
field-names	Durch Kommas getrennte Liste der Feldnamen, die vom abzufragenden Objekt angefordert werden. Wenn Sie dieses Feld leer lassen, werden alle Felder abgefragt.
include-deleted-records	Bei „true“ nimmt der Prozessor gelöschte Datensätze (IsDeleted = true) in die Abfrageergebnisse auf. Wenn diese Option aktiviert ist, verwendet der Prozessor die Funktion „queryAll“-API.
initial-age-filter	Diese Eigenschaft gibt die Startzeit an, die der Prozessor bei der Ausführung der ersten Abfrage anwendet.
oauth2-access-token-provider	Dienst, der OAuth2-Zugriffstoken für die Authentifizierung über den HTTP-Autorisierungs-Header bereitstellt.
query-type	Wählen Sie, ob Sie die Abfrage über Parameter oder eine vollständige benutzerdefinierte Abfrage bereitstellen möchten.
read-timeout	Maximal zulässige Zeit für das Lesen einer Antwort aus der Salesforce REST-API
record-writer	Dienst, der für das Schreiben von Datensätzen verwendet wird, die von der Salesforce REST-API zurückgegeben werden.
salesforce-api-version	Die Versionsnummer der Salesforce REST-API, die an die URL nach dem Pfad services/data angehängt ist. Siehe Salesforce-Dokumentation für unterstützte Versionen
salesforce-url	Die URL der Salesforce-Instanz einschließlich der Domäne ohne zusätzliche Pfadangaben, z. B. https://MyDomainName.my.salesforce.com
sobject-name	Das Salesforce sObject, das abgefragt werden soll

Statusmanagement¶

Bereiche	Beschreibung
CLUSTER	Wenn „Age Field“ eingestellt ist, wird nach der Durchführung einer Abfrage der Zeitpunkt der Ausführung gespeichert. Nachfolgende Abfragen werden mit einer zusätzlichen Bedingung ergänzt, so dass nur Datensätze abgerufen werden, die neuer sind als die gespeicherte Ausführungszeit (angepasst mit dem optionalen Wert von „Age Delay“). Der Status wird im gesamten Cluster gespeichert, sodass dieser Prozessor nur auf dem primären Knoten ausgeführt werden kann. Wenn ein neuer primärer Knoten ausgewählt wird, kann der neue Knoten dort weitermachen, wo der vorherige Knoten aufgehört hat, ohne die Daten zu duplizieren.

Bereiche

Beschreibung

CLUSTER

Wenn „Age Field“ eingestellt ist, wird nach der Durchführung einer Abfrage der Zeitpunkt der Ausführung gespeichert. Nachfolgende Abfragen werden mit einer zusätzlichen Bedingung ergänzt, so dass nur Datensätze abgerufen werden, die neuer sind als die gespeicherte Ausführungszeit (angepasst mit dem optionalen Wert von „Age Delay“). Der Status wird im gesamten Cluster gespeichert, sodass dieser Prozessor nur auf dem primären Knoten ausgeführt werden kann. Wenn ein neuer primärer Knoten ausgewählt wird, kann der neue Knoten dort weitermachen, wo der vorherige Knoten aufgehört hat, ohne die Daten zu duplizieren.

Beziehungen¶

Name	Beschreibung
failure	Wenn die Abfrage fehlschlägt, wird die Eingabedatei an diese Beziehung gesendet.
original	Die Eingabedatei wird an diese Beziehung gesendet, wenn die Abfrage erfolgreich war.
success	Für FlowFiles, die als Ergebnis einer erfolgreichen Abfrage erstellt wurden.

Schreibt Attribute¶

Name	Beschreibung
mime.type	Setzt das Attribut „mime.type“ auf den vom Record Writer angegebenen MIME-Typ.
record.count	Legt die Anzahl der Datensätze im FlowFile fest.
total.record.count	Legt die Gesamtzahl der Datensätze im FlowFile fest.

Siehe auch:¶

org.apache.nifi.processors.salesforce.PutSalesforceObject