PutSnowflakeInternalStageFile 2025.5.31.15

Bundle

com.snowflake.openflow.runtime | runtime-snowflake-processors-nar

Beschreibung

Legt Dateien in einem internen Stagingbereich von Snowflake ab. Der interne Stagingbereich muss zuvor im Snowflake-Konto erstellt werden.

Tags

connection, database, jdbc, openflow, snowflake, snowpipe

Eingabeanforderung

REQUIRED

Unterstützt sensible dynamische Eigenschaften

false

Eigenschaften

Eigenschaft

Beschreibung

Compression Enabled

Setzen Sie „true“, um die Daten vor dem Hochladen zu komprimieren.

Datenbank

Die standardmäßig zu verwendende Datenbank. Dasselbe wie die Übergabe von „db=DATABASE_NAME“ an die Verbindungszeichenfolge.

Dateiname

Name der zu verwendenden Zieldatei.

File Prefix

Pfadpräfix, unter dem die Daten in den Stagingbereich hochgeladen werden sollen.

Internal Stage Type

Der Typ des zu verwendenden internen Stagingbereichs

Schema

Das Schema, das standardmäßig verwendet werden soll. Dasselbe wie die Übergabe von „schema=SCHEMA“ an die Verbindungszeichenfolge.

Snowflake Connection Service

Datenbankverbindungsdienst für den Zugriff auf Snowflake

Stagingbereich

Der Name des internen Stagingbereichs im Snowflake-Konto, in dem die Dateien abgelegt werden.

Tabelle

Der Name der Tabelle im Snowflake-Konto.

Beziehungen

Name

Beschreibung

failure

Für FlowFiles der fehlgeschlagenen PUT-Operation

success

Für FlowFiles der erfolgreichen PUT-Operation

Schreibt Attribute

Name

Beschreibung

snowflake.staged.file.path

Pfad der Stagingdatei