Snowflake: アップサートアクション
Workatoでは、バッチと単一のアップサート行アクションの両方を提供しています。 これにより、レシピに必要なアクションを選択し、ビジネスニーズを満たす柔軟性が得られます。
行のバッチのアップサート
このアクションを使用すると、1行ずつではなく、1つのアクションで複数の行をアップサートできます。 これにより、あるアプリからSnowflakeへ大量のレコードを移動する際に、より高いスループットが得られます。 レシピの構造およびデータ量によっては、このアクションにより連携時間を100分の1に短縮できます。
タイムアウトエラー
行をアップサートバッチアクションは、Timed out reading data from serverまたはBad Gateway: context canceledエラーでタイムアウトする場合があります。
これは、接続されたSnowflakeウェアハウスが過負荷になっている場合に発生します。 タイムアウトを防ぐには、ウェアハウスのサイズを大きくします。
行のバッチをアップサートするアクション
テーブル
単一行のアップサートアクションと同様に、最初にターゲットテーブルを選択する必要があります。
行のソースリスト
Upsert rowアクション(単一行を扱う場合)とは異なり、ここでは行のバッチを扱います。 したがって、次に入力するデータピルは、テーブルにアップサートする行のバッチのソースです。 これは、リストデータピルを出力する任意のトリガーまたはアクションから取得できます。
リストデータピルをこのフィールドにマッピングしない場合、このアクションは1行のみをアップサートし、Upsert rowアクションと同様に動作します。
列
最後に、先行するトリガーまたはアクションからのデータで行をアップサートするには、出力データツリーから必要なフィールドをここにマッピングする必要があります。 ここで各列にマッピングするデータピルは、先ほど使用したソースリストデータピルからのものである必要がある点に注意してください。 ソースリストデータピルの外部でマッピングされたデータピルは反復処理されません(このようなマッピングはすべての行に対して定数値になります)。
Upsert rowアクションと同様に、指定された主キー値は、各行に対して更新または作成のどちらを行うかを判断するために使用されます。
バッチの操作に関する詳細については、リスト管理ガイドを参照してください。
次のステップ
WorkatoがSnowflake向けに提供するその他のトリガーとアクションについて詳しく見る
または、今すぐレシピの構築を開始しましょう。 以下をご覧ください
Last updated: