ListDatabaseTables 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-standard-nar

Beschreibung¶

Erzeugt eine Reihe von FlowFiles, die jeweils Attribute enthalten, die den Metadaten einer Tabelle aus einer Datenbankverbindung entsprechen. Sobald Metadaten zu einer Tabelle abgerufen wurden, werden sie erst wieder abgerufen, wenn das Aktualisierungsintervall (sofern festgelegt) abgelaufen ist oder der Status manuell gelöscht wurde.

Tags¶

database, jdbc, list, sql, table

Eingabeanforderung¶

FORBIDDEN

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
list-db-include-count	Ob die Zeilenzahl der Tabelle als Attribut des FlowFile aufgenommen werden soll. Dies beeinträchtigt die Leistung, da für jede Tabelle in der abgerufenen Liste eine Datenbankabfrage erstellt wird.
list-db-refresh-interval	Die Zeit, die verstreichen muss, bevor der Prozessorstatus zurückgesetzt wird, wodurch alle aktuellen Tabellen aufgelistet werden. Während dieses Intervalls kann der Prozessor weiterlaufen, aber Tabellen, die bereits aufgelistet wurden, werden nicht erneut aufgelistet. Neue/hinzugefügte Tabellen werden jedoch während der Ausführung des Prozessors aufgelistet. Ein Wert von Null bedeutet, dass der Status nie automatisch zurückgesetzt wird. Der Benutzer muss den Status manuell löschen.
list-db-tables-catalog	Der Name eines Katalogs, aus dem Datenbanktabellen aufgelistet werden sollen. Der Name muss mit dem Katalognamen übereinstimmen, wie er in der Datenbank gespeichert ist. Wenn die Eigenschaft nicht festgelegt ist, wird der Katalogname nicht zur Eingrenzung der Suche nach Tabellen verwendet. Wenn die Eigenschaft auf eine leere Zeichenfolge gesetzt ist, werden Tabellen ohne Katalog aufgelistet.
list-db-tables-db-connection	Der Controller Service, der verwendet wird, um eine Verbindung zur Datenbank herzustellen
list-db-tables-name-pattern	Ein Muster für passende Tabellen in der Datenbank. Innerhalb eines Musters bedeutet „%“, dass eine beliebige Teilfolge von 0 oder mehr Zeichen übereinstimmt, und „_“ bedeutet, dass ein beliebiges Zeichen übereinstimmt. Das Muster muss mit dem Tabellennamen übereinstimmen, wie er in der Datenbank gespeichert ist. Wenn die Eigenschaft nicht gesetzt ist, werden alle Tabellen abgerufen.
list-db-tables-schema-pattern	Ein Muster für den Abgleich von Schemas in der Datenbank. Innerhalb eines Musters bedeutet „%“, dass eine beliebige Teilfolge von 0 oder mehr Zeichen übereinstimmt, und „_“ bedeutet, dass ein beliebiges Zeichen übereinstimmt. Das Muster muss mit dem Schemanamen übereinstimmen, wie er in der Datenbank gespeichert ist. Wenn die Eigenschaft nicht festgelegt ist, wird der Schemaname nicht zur Eingrenzung der Suche nach Tabellen verwendet. Wenn die Eigenschaft auf eine leere Zeichenfolge gesetzt ist, werden Tabellen ohne Schema aufgelistet.
list-db-tables-types	Eine durch Kommas getrennte Liste der einzubeziehenden Tabellentypen. Einige Datenbanken unterstützen zum Beispiel die Typen TABLE und VIEW. Wenn die Eigenschaft nicht gesetzt ist, werden Tabellen aller Typen zurückgegeben.
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.

Statusmanagement¶

Bereiche	Beschreibung
CLUSTER	Nach dem Auflisten der Tabellen wird der Zeitstempel der Abfrage gespeichert. Dadurch muss der Prozessor die Tabellen beim nächsten Start nicht erneut auflisten. Wenn Sie das Aktualisierungsintervall in den Prozessoreigenschaften angeben, wird der Status zurückgesetzt, wenn der Prozessor feststellt, dass das Intervall abgelaufen ist, und die Tabellen werden daraufhin neu aufgelistet. Dieser Prozessor sollte nur auf dem primären Knoten ausgeführt werden.

Bereiche

Beschreibung

CLUSTER

Nach dem Auflisten der Tabellen wird der Zeitstempel der Abfrage gespeichert. Dadurch muss der Prozessor die Tabellen beim nächsten Start nicht erneut auflisten. Wenn Sie das Aktualisierungsintervall in den Prozessoreigenschaften angeben, wird der Status zurückgesetzt, wenn der Prozessor feststellt, dass das Intervall abgelaufen ist, und die Tabellen werden daraufhin neu aufgelistet. Dieser Prozessor sollte nur auf dem primären Knoten ausgeführt werden.

Beziehungen¶

Name	Beschreibung
success	Alle FlowFiles, die empfangen werden, werden an die Beziehung „success“ weitergeleitet.

Schreibt Attribute¶

Name	Beschreibung
db.table.name	Enthält den Namen einer Datenbanktabelle aus der Verbindung.
db.table.catalog	Enthält den Namen des Katalogs, zu dem die Tabelle gehört (kann null sein).
db.table.schema	Enthält den Namen des Schemas, zu dem die Tabelle gehört (kann null sein).
db.table.fullname	Enthält den vollständig qualifizierten Tabellennamen (möglicherweise einschließlich Katalog, Schema usw.)
db.table.type	Enthält den Typ der Datenbanktabelle aus der Verbindung. Typische Typen sind „TABLE“, „VIEW“, „SYSTEM TABLE“, „GLOBAL TEMPORARY“, „LOCAL TEMPORARY“, „ALIAS“, „SYNONYM“
db.table.remarks	Enthält den Namen einer Datenbanktabelle aus der Verbindung.
db.table.count	Enthält die Anzahl der Zeilen in der Tabelle.

Anwendungsfälle mit anderen Komponenten¶

Führen Sie eine vollständige Datenbankladung durch, wobei alle Zeilen aus allen Tabellen oder einem bestimmten Satz von Tabellen abgerufen werden.