Amazon SNS のSnowpipeエラー通知の有効化¶

IAM ユーザー ARN と SNS トピック外部 ID の取得¶

1. DESCRIBE INTEGRATION を実行します。

   DESC NOTIFICATION INTEGRATION <integration_name>;
   

   Copy

   条件:

   • integration_name は、 ステップ4: 通知統合を作成する （このトピック内）で作成した通知統合の名前です。

   例:

   DESC NOTIFICATION INTEGRATION my_notification_int;
   
   +---------------------------+-------------------+------------------------------------------------------+----------------------+
   |   property                |   property_type   |   property_value                                     |   property_default   |
   +---------------------------+-------------------+------------------------------------------------------+----------------------+
   |   ENABLED                 |   Boolean         |   true                                               |   false              |
   |   NOTIFICATION_PROVIDER   |   String          |   AWS_SNS                                            |                      |
   |   DIRECTION               |   String          |   OUTBOUND                                           |   INBOUND            |
   |   AWS_SNS_TOPIC_ARN       |   String          |   arn:aws:sns:us-east-2:111122223333:myaccount       |                      |
   |   AWS_SNS_ROLE_ARN        |   String          |   arn:aws:iam::111122223333:role/myrole              |                      |
   |   SF_AWS_IAM_USER_ARN     |   String          |   arn:aws:iam::123456789001:user/c_myaccount         |                      |
   |   SF_AWS_EXTERNAL_ID      |   String          |   MYACCOUNT_SFCRole=2_a123456/s0aBCDEfGHIJklmNoPq=   |                      |
   +---------------------------+-------------------+------------------------------------------------------+----------------------+
   

   Copy

2. 生成された次の値を記録します。

   SF_AWS_IAM_USER_ARN:

   アカウント用に作成されたSnowflake IAM ユーザーの ARN。Snowflakeアカウントのユーザーは、通知統合を使用してこのユーザーの外部 ID を送信することにより、 ステップ3: AWS IAM ロールを作成する で作成した IAM ロールを引き受けます。

   SF_AWS_EXTERNAL_ID:

   使用するアカウント用に作成されたSnowflake IAM ユーザーの外部 ID。

   次のステップでは、 IAM ロールの信頼関係をこれらの値で更新します。

DIRECTION プロパティは、Snowflakeに関するクラウドメッセージングの方向を示していることに注意してください。

IAM ロールの信頼関係の変更¶

1. AWS 管理コンソールにログインします。

2. ホームダッシュボードから、 Identity & Access Management （IAM）を選択します。

3. 左側のナビゲーションペインから Roles を選択します。

4. ステップ3: AWS IAM ロールを作成する （このトピック内）で作成したロールをクリックします。

5. Trust relationships タブをクリックします。

6. Edit trust relationship ボタンをクリックします。

7. IAM ユーザーの ARN および SNS トピックの外部 ID （このトピック内）で記録した DESC NOTIFICATION INTEGRATION 出力値でポリシードキュメントを変更します。

   IAM ロールのポリシードキュメント

   {
     "Version": "2012-10-17",
     "Statement": [
       {
         "Sid": "",
         "Effect": "Allow",
         "Principal": {
           "AWS": "<sf_aws_iam_user_arn>"
         },
         "Action": "sts:AssumeRole",
         "Condition": {
           "StringEquals": {
             "sts:ExternalId": "<sf_aws_external_id>"
           }
         }
       }
     ]
   }
   

   Copy

   条件:

   • sf_aws_iam_user_arn は、記録した SF_AWS_IAM_USER_ARN 値です。

   • sf_aws_external_id は、記録した SF_AWS_EXTERNAL_ID 値です。

8. Update Trust Policy ボタンをクリックします。変更が保存されます。

新しいパイプ¶

CREATE PIPE を使用して新しいパイプを作成します。自動データロードの構成（つまり、自動インジェストSnowpipe）には、追加のパイプパラメーターが必要であることに注意してください。手順については、 クラウドメッセージングを使用した連続データロードの自動化 をご参照ください。

CREATE PIPE <name>
  [ AUTO_INGEST = TRUE | FALSE  ]
  ERROR_INTEGRATION = <integration_name>
  AS <copy_statement>

条件:

ERROR_INTEGRATION = <統合名>

ステップ4: 通知統合を作成する （このトピック内）で作成した通知統合の名前です。

次の例は、エラー通知と自動データロードの両方をサポートする CREATE PIPE ステートメントを示しています。

CREATE PIPE mypipe
  AUTO_INGEST = TRUE
  ERROR_INTEGRATION = my_notification_int
  AS
  COPY INTO mydb.public.mytable
  FROM @mydb.public.mystage;

既存のパイプ¶

ALTER PIPE を使用して既存のパイプを変更します。

ALTER PIPE <name> SET ERROR_INTEGRATION = <integration_name>;

ここで、 <統合名> は、 ステップ4: 通知統合を作成する （このトピック内）で作成した通知統合の名前です。

例:

ALTER PIPE mypipe SET ERROR_INTEGRATION = my_notification_int;