PutSnowpipeStreaming2 2025.10.2.19¶

バンドル¶

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

説明¶

Snowpipe Streamingバージョン2を使用して、改行区切り JSONとしてフォーマットされた記録をSnowflakeデータベースパイプに送信します。

タグ¶

NDJSON、プレビュー、Snowflake、Snowpipe Streaming

入力要件¶

REQUIRED

機密動的プロパティをサポート¶

false

プロパティ¶

プロパティ	説明
アカウント	組織名とアカウント名が [organization-name]-[account-name]の形式で記述された Snowflake アカウント識別子。
認証ストラテジー	Snowflake接続認証コードのストラテジー
チャネルグループ	パーティショニングされたSnowpipe Streamingチャネルを管理するグループ
チャネル挿入タイムアウト	レコードの挿入に失敗するまでの最大再試行時間（上限は5分）
データベース	処理された記録のSnowflakeデータベース宛先
ファイルフラグメントカウント	入力 FlowFilesからSnowpipe Streamingインジェスト用にオブジェクトストレージに送信されるファイルフラグメントの最大数。1～100の間である必要があります。
ファイルフラグメントサイズ	Snowpipe Streamingインジェスト用にオブジェクトストレージに送信される各ファイルフラグメントの最大サイズ（バイト単位）。1 KB～256 MBの間である必要があります。
オフセットトークン終了式	FlowFileの、単調に増加する数として最も高いオフセットトークンを生成する式言語定義
オフセットトークンレコードポインター	最後にコミットされたオフセットトークンが開始と終了の境界の間にある場合に必要な、各レコード内のオフセットトークンへの JSONポインター。
オフセットトークン開始式	FlowFileの最低オフセットトークンを単調増加数として生成する式言語定義
オフセットトラッキングタイムアウト	コミットされたオフセットトークンのチャネルステータスをポーリングする最大時間
パイプ	処理されたレコードのSnowflakeパイプの宛先
秘密キーサービス	接続認証用 RSA プライベートキーサービス
スキーマ	処理済み記録のSnowflakeスキーマ送信先
転送戦略	Snowpipe Streamingへのレコード転送戦略
ユーザー	接続認証用Snowflakeユーザー
ウェブクライアントサービスプロバイダー	HTTPリクエストとレスポンスの処理をサポートするウェブクライアントサービスプロバイダー

リレーションシップ¶

名前	説明
failure	Snowflakeへのアップロードに失敗した FlowFiles
invalid	Snowflakeが1つ以上の無効な行が含まれていると認識したため、部分的に送信された FlowFiles
success	Snowflakeへのアップロードに成功した FlowFiles