PutSnowpipeStreaming2 2025.10.2.19¶

Bundle¶

com.snowflake.openflow.runtime | runtime-snowpipe-streaming-2-processors-nar

Beschreibung¶

Sendet Datensätze, die im „Newline Delimited“ JSON-Format formatiert sind, mit Snowpipe Streaming Version 2 an Snowflake Datenbank-Pipes.

Tags¶

NDJSON, Vorschau, Snowflake, Snowpipe Streaming

Eingabeanforderung¶

REQUIRED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
Konto	Snowflake-Kontobezeichner mit dem Organisationsnamen und Kontonamen, formatiert als [organisation-name]-[account-name]
Authentication Strategy	Strategie zur Authentifizierung von Snowflake-Verbindungen
Channel Group	Gruppe zum Verwalten verschiedener Snowpipe Streaming-Kanäle mit Partitionierung
Channel Insert Timeout	Maximale Dauer für das wiederholte Einfügen von Datensätzen, bevor das Problem fehlschlägt, mit einer Obergrenze von 5 Minuten
Datenbank	Snowflake-Datenbankziel für verarbeitete Datensätze
File Fragment Count	Maximale Anzahl von Dateifragmenten, die von Eingabe-FlowFiles an den Objektspeicher für die Snowpipe Streaming-Erfassung gesendet werden. Muss zwischen 1 und 100 liegen.
File Fragment Size	Maximale Größe in Bytes für jedes Dateifragment, das an den Objektspeicher zur Snowpipe Streaming-Erfassung gesendet wird. Muss zwischen 1 KB und 256 MB liegen
Endausdruck des Offset-Tokens	Ausdruckssprachendefinition, um das höchste Offset-Token für ein FlowFile als monoton zunehmende Zahl zu erzeugen
Offset Token Record Pointer	JSON-Zeiger auf das Offset-Token in jedem Datensatz, der erforderlich ist, wenn sich das zuletzt übertragene Offset-Token zwischen Start- und Endgrenzen befindet
Startausdruck des Offset-Tokens	Ausdruckssprachendefinition, um das niedrigste Offset-Token für ein FlowFile als monoton zunehmende Zahl zu erzeugen
Offset Tracking Timeout	Maximale Dauer für das Abfragen des Kanalstatus für bestätigte Offset-Token
Pipe	Snowflake Pipe-Ziel für verarbeitete Datensätze
Private Key Service	RSA Private Key Service zur Authentifizierung von Verbindungen
Schema	Snowflake Schema-Ziel für verarbeitete Datensätze
Transfer Strategy	Strategie für die Übertragung von Datensätzen an Snowpipe Streaming
Benutzer	Snowflake-Benutzer für die Authentifizierung von Verbindungen
Web Client Service Provider	Web Client Service Provider, der HTTP-Verarbeitung von Anfragen und Antworten unterstützt

Beziehungen¶

Name	Beschreibung
failure	FlowFiles, die nicht in Snowflake hochgeladen werden konnten
invalid	FlowFiles, in denen Snowflake eine oder mehrere ungültige Zeilen identifiziert hat, was zu einer teilweisen Übertragung führte
success	Erfolgreich in Snowflake hochgeladene FlowFiles