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