ListSmb 2025.10.2.19¶
Bundle¶
org.apache.nifi | nifi-smb-nar
Beschreibung¶
Listet konkrete Dateien auf, die über das SMB-Protokoll freigegeben wurden. Jede aufgelistete Datei kann zu einem FlowFile führen, wobei die Metadaten als FlowFile-Attribute geschrieben werden. Oder – falls die Eigenschaft „Record Writer“ gesetzt ist – das gesamte Ergebnis wird als Datensätze in ein einzelnes FlowFile geschrieben. Dieser Prozessor ist für den Betrieb auf dem primären Knoten in einem Cluster vorgesehen. Wenn sich der primäre Knoten ändert, macht der neue primäre Knoten dort weiter, wo der vorherige Knoten aufgehört hat, ohne alle Daten zu duplizieren.
Eingabeanforderung¶
FORBIDDEN
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
directory |
Der Netzwerkordner, aus dem Dateien aufgelistet werden sollen. Dies ist der verbleibende relative Pfad nach der Freigabe: smb://HOSTNAME:PORT/SHARE/[DIRECTORY]/sub/directories. Es ist auch möglich, Unterverzeichnisse hinzuzufügen. Der angegebene Pfad zur Remote-Dateifreigabe muss existieren. Dies kann mithilfe der Verifizierung überprüft werden. Sie können Windows- und Linux-Verzeichnistrennzeichen mischen. |
et-initial-listing-target |
Geben Sie an, wie das erstmalige Freigabeangebot behandelt werden soll. Wird von der „Entitäten verfolgen“-Strategie verwendet. |
et-state-cache |
Die aufgelisteten Entitäten werden im angegebenen Cachespeicher gespeichert, sodass dieser Prozessor das Freigabeangebot über den NiFi-Neustart hinweg oder im Falle einer Änderung des Primärknotens fortsetzen kann. Die Strategie „Entitäten verfolgen“ erfordert Verfolgungsinformationen zu allen aufgelisteten Entitäten innerhalb des letzten Zeitfensters zur Verfolgung. Um eine große Anzahl von Entitäten zu unterstützen, verwendet die Strategie DistributedMapCache anstelle von verwaltetem Status. Das Format des Cacheschlüssels ist ‚ListedEntities::{processorId}(::{nodeId})‘. Wenn die aufgelisteten Entitäten pro Knoten verfolgt werden, wird der optionale Teil ‚::{nodeId}‘ hinzugefügt, um den Status separat zu verwalten. Beispiel: Clusterweiter Cache-Schlüssel =‘ListedEntities::8dda2321-0164-1000-50fa-3042fe7d6a7b‘, pro Knoten-Cacheschlüssel =‘ListedEntities::8dda2321-0164-1000-50fa-3042fe7d6a7b::nifi-node3‘ Der Inhalt des gespeicherten Cache ist eine Gzipped JSON-Zeichenfolge. Der Cacheschlüssel wird gelöscht, wenn die Konfiguration des Ziel-Freigabeangebots geändert wird. Wird von der „Entitäten verfolgen“-Strategie verwendet. |
et-time-window |
Geben Sie an, wie lange dieser Prozessor bereits aufgelistete Entitäten verfolgen soll. Die Strategie „Entitäten verfolgen“ kann jede Entität auswählen, deren Zeitstempel innerhalb des angegebenen Zeitfensters liegt. Werden z. B. „30 Minuten“ eingestellt, wird jede Entität, deren Zeitstempel in den letzten 30 Minuten liegt, zum Ziel des Freigabeangebots, wenn dieser Prozessor ausgeführt wird. Eine aufgelistete Entität gilt als „neu/aktualisiert“ und wird als FlowFile ausgegeben, wenn eine der folgenden Bedingungen erfüllt ist: 1. existiert nicht in den bereits aufgelisteten Entitäten, 2. hat einen neueren Zeitstempel als die zwischengespeicherte Entität, 3. hat eine andere Größe als die zwischengespeicherte Entität. Wenn der Zeitstempel einer zwischengespeicherten Entität älter wird als das angegebene Zeitfenster, wird diese Entität aus den zwischengespeicherten, bereits aufgelisteten Entitäten entfernt. Wird von der „Entitäten verfolgen“-Strategie verwendet. |
file-filter |
Es werden nur Dateien aufgelistet, deren Namen mit dem angegebenen regulären Ausdruck übereinstimmen. |
filename-suffix-filter |
Dateien, die mit dem angegebenen Suffix enden, werden ausgelassen. Kann verwendet werden, um sicherzustellen, dass Dateien, die noch hochgeladen werden, nicht mehrfach aufgelistet werden, indem diesen Dateien ein Suffix hinzugefügt und dieses Suffix nach Abschluss des Uploads wieder entfernt wird. Dies ist sehr empfehlenswert, wenn Sie die Auflistungsstrategien „Tracking Entities“ oder „Tracking Timestamps“ verwenden. |
initial-listing-strategy |
Gibt an, wie vorhandene Dateien auf der SMB-Freigabe behandelt werden sollen, wenn der Prozessor zum ersten Mal gestartet wird (oder sein Status gelöscht wurde). |
initial-listing-timestamp |
Der Zeitstempel, ab dem die Dateien aufgelistet werden, wenn der Prozessor zum ersten Mal gestartet wird (oder sein Status gelöscht wurde). Der Wert kann als Epoch-Zeitstempel in Millisekunden oder als UTC-Datumszeit in einem Format wie 2025-02-01T00:00:00Z angegeben werden. |
listing-strategy |
Legen Sie fest, wie neue/aktualisierte Entitäten ermittelt werden sollen. Weitere Informationen finden Sie in den Beschreibungen der einzelnen Strategien. |
max-file-age |
Alle Dateien, die älter als der angegebene Wert sind, werden ausgelassen. |
max-file-size |
Jede Datei, die größer als der angegebene Wert ist, wird ausgelassen. |
min-file-age |
Das Mindestalter, das eine Datei haben muss, um aufgelistet zu werden; alle Dateien, die jünger sind als dieser Zeitraum, werden ignoriert. |
min-file-size |
Jede Datei, die kleiner als der angegebene Wert ist, wird ausgelassen. |
path-filter |
Es werden nur Dateien aufgelistet, deren Pfade (bis zum übergeordneten Verzeichnis der Datei) mit dem angegebenen regulären Ausdruck übereinstimmen. |
record-writer |
Gibt den Record Writer an, der zum Erstellen der Liste verwendet werden soll. Wenn nicht angegeben, wird für jede aufgelistete Entität ein FlowFile erstellt. Wenn der Record Writer angegeben ist, werden alle Entitäten in ein einziges FlowFile geschrieben, anstatt Attribute zu einzelnen FlowFiles hinzuzufügen. |
smb-client-provider-service |
Gibt den SMB-Client-Anbieter an, der für die Erstellung von SMB-Verbindungen verwendet werden soll. |
target-system-timestamp-precision |
Geben Sie die Zeitstempelgenauigkeit auf dem Zielsystem an. Da dieser Prozessor den Zeitstempel von Entitäten verwendet, um zu entscheiden, welche aufgelistet werden sollen, ist es wichtig, die richtige Zeitstempelgenauigkeit zu verwenden. |
Statusmanagement¶
Bereiche |
Beschreibung |
|---|---|
CLUSTER |
Nach dem Erstellen einer Dateiliste kann der Status der vorherigen Auflistung gespeichert werden, um Dateien fortlaufend ohne Duplikate aufzulisten. |
Beziehungen¶
Name |
Beschreibung |
|---|---|
success |
Alle FlowFiles, die empfangen werden, werden an die Beziehung „success“ weitergeleitet. |
Schreibt Attribute¶
Name |
Beschreibung |
|---|---|
filename |
Der Name der Datei, die aus dem Dateisystem gelesen wurde. |
shortName |
Der Kurzname der Datei, die aus dem Dateisystem gelesen wurde. |
Pfad |
Der Pfad wird auf den relativen Pfad des Verzeichnisses der Datei auf dem Remote-Dateisystem im Vergleich zum Share-Stammverzeichnis gesetzt. Wenn ein Remote-Speicherort unter smb://HOSTNAME:PORT/SHARE/DIRECTORY definiert ist und eine Datei aus smb://HOSTNAME:PORT/SHARE/DIRECTORY/sub/folder/file aufgelistet wird, dann wird das Attribut „DIRECTORY/sub/folder“ gesetzt. |
serviceLocation |
Die SMB URL der Freigabe. |
lastModifiedTime |
Der Zeitstempel, wann der Inhalt der Datei im Dateisystem geändert wurde, als „yyyy-MM-dd’T’HH: mm:ss“. |
creationTime |
Der Zeitstempel, wann die Datei im Dateisystem erstellt wurde als „yyyy-MM-dd’T’HH: mm:ss“. |
lastAccessTime |
Der Zeitstempel, wann auf die Datei im Dateisystem zugegriffen wurde, als „yyyy-MM-dd’T’HH: mm:ss“. |
changeTime |
Der Zeitstempel, wann die Dateiattribute im Dateisystem geändert wurden, als „yyyy-MM-dd’T’HH: mm:ss“. |
size |
Die Größe der Datei in Bytes. |
allocationSize |
Die Anzahl der Bytes, die für die Datei auf dem Server reserviert sind. |