Integration Service のアクティビティ

最終更新日時 2025年3月24日

テクニカルリファレンス

Snowflake アクティビティを使用する

先端：このページには、Snowflake アクティビティを使用する際に役立つヒントがいくつか含まれています。

クエリの結果が大きな行セットになることが予想される場合は、常に LIMIT と OFFSET を使用して結果をページ分割します。このユースケースのクエリ例については、Snowflake のドキュメントをご参照ください。
[出力スキーマの生成] は 、ワークフロー変数を含まないクエリステートメントに対してのみ正常に機能します。出力スキーマが生成されたら、クエリを変数に置き換えることができます。 Snowflakeで直接正常に実行できるクエリを使用することをお勧めします。
実行に 30 秒以上かかるクエリには、[ 任意のクエリを非同期的に実行 ] を使用します。
選択以外のコマンド (挿入、更新、ストアドプロシージャなど) は、[ 任意のクエリを非同期に実行 ] アクティビティでのみ実行できます。
[ 非同期クエリ実行ステータスを取得 ] アクティビティは、[ 任意のクエリを非同期的に実行] の出力から取得したクエリ ID で使用します。
[非同期クエリのステータスの変更] トリガーを使用すると、クエリが正常に実行されたとき、またはエラーが発生したときにプロセスを開始できます。
非同期クエリの結果を取得するには、[ 非同期クエリの実行ステータスを取得] を使用します。[ 任意のクエリを非同期的に実行 ] の出力のクエリ ID を使用して、出力スキーマを生成します。スキーマが生成されたら、変数クエリ ID を使用できます。入力を変数に変更しても、出力プロパティには影響しません。出力プロパティは変わりません。つまり、生成された出力は手動で再生成しない限り変更できません。必要に応じて、別のワークフロープロセスを設定することをお勧めします。デスクトップ版の Studio を使用している場合は、Snowflake パッケージバージョン 5.0.1 の [ネイティブ検索 ] アクティビティを使用できます。
[レコードの作成時] トリガーと [更新されたレコード] トリガーを正常に実行するには、イベントを監視しているテーブルに対して、ALTER TABLE [TABLE_NAME] SET CHANGE_TRACKING = TRUE;というクエリを実行する必要があります。さらに、Snowflake で必要な権限が構成されていることを確認してください。

Snowflake で行を挿入する際の主キー出力の識別

自動的にインクリメントされる ID 列を含むテーブルがある場合、一般的なユースケースは、そのテーブルに行を挿入し、作成された行の ID を出力する処理です。

この問題の最も簡単な回避策は、データをオフロードするテーブルで外部キーリレーションシップを維持することです。次の例では、Snowflake の [レコードを挿入 ] アクティビティで、[出力] SNOWFLAKE_IDがあっても、実行中に行が追加されたときに実際の出力がないことがわかります。これは Snowflake の制限です。したがって、このテーブルの外部キー列 (SFDC_OPPORTUNITY_ID) を維持します。