QuerySalesforceObject 2025.5.31.15¶

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“ festlegen. Der Prozessor kann auch eine benutzerdefinierte Abfrage ausführen, wobei in diesem Fall jedoch keine Datensatzverarbeitung unterstützt wird. Unterstützt den inkrementellen Abruf: Benutzer können in der Eigenschaft „Age Field“ ein Feld definieren, das zur Bestimmung des Erstellungsdatums des Datensatzes verwendet wird. Wenn diese Eigenschaft gesetzt ist, ruft der Prozessor neue Datensätze ab. Inkrementelles Laden und datensatzbasierte Verarbeitung werden nur bei eigenschaftsbasierten Abfragen unterstützt. Es ist auch möglich, einen anfänglichen Grenzwert für das Alter festzulegen, wodurch alle älteren Datensätze bereits beim ersten Durchlauf herausgefiltert werden. Im Falle einer eigenschaftsbasierten Abfrage sollte dieser Prozessor nur auf dem Primärknoten laufen. 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 in der Abfrage auf die FlowFile-Attribute verweisen. Wenn „Include Deleted Records“ wahr ist, wird der Prozessor gelöschte Datensätze (soft-deletes) in die Ergebnisse einbeziehen, indem er die „queryAll“-API verwendet. Das Feld „IsDeleted“ wird bei der Abfrage von gelöschten Datensätzen 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 zum Filtern von Datensätzen mit einem begrenzten Zeitfenster verwendet wird. Der Prozessor gibt nur die Datensätze zurück, deren Zeitstempelwert neuer ist als der Zeitstempel, der nach dem letzten Prozessorlauf erfasst 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