テクニカル リファレンス

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) を維持します。

行が追加されたら、Snowflake の [ネイティブ検索] アクティビティを使用して外部キー (SFDC_OPPORTUNITY_ID) と引き換えに主キー (SNOWFLAKE_IDを照会し、後続の [行項目を取得] システム アクティビティを使用することができます。

返された SNOWFLAKE_ID (主キー) はアップストリーム アプリケーションのカスタム フィールド (この場合は Salesforce) に格納することもできるため、更新を連続して実行する必要がある場合でも、毎回外部キーを使用して ID を照会する必要はありません。