Learn how to create a Snowpipe that copies data to the target table from the external stage in Snowflake.

1. In the Snowflake application worksheet area, create a new SQL worksheet.
2. In the SQL worksheet, run this command:

   create pipe "<database_name>"."<schema_name>"."<pipe_name>" auto_ingest=true
   integration=<notification_integration_name>
   as
     copy into "<database_name>"."<schema_name>"."<landing_table_name>"
   from (select $1:uri::string, $1:version::string, $1:timestamp::string, $1:deleted::boolean, $1:linked::boolean, $1:objectType::string, $1:type::string, $1, current_timestamp() from @"<database_name>"."<schema_name>"."<stage_name>")
     file_format = "<database_name>"."<schema_name>"."<file_format_name>";

   where:

   • <database_name>: Is the name of the database you created in Create a Snowflake database.

   • <schema_name>: Is the name of the schema you created in Create a Snowflake schema.

   • <pipe_name>: Is the name of this Snowpipe you are creating.

   • <notification_integration_name>: Is the name of the notification integration you created in Create event notification integrations in Snowflake (Azure).

     Attention: The notification integration name must be typed in all uppercase.

   • <landingtable_name>: Is the name of the landing data table you created in Create a landing data table in Snowflake.

   • <stage_name>: Is the name of the stage you created in Create an external stage (Azure).

   • <file_format_name>: is the name of the JSON file format you created in Create a JSON file format in Snowflake.

   CREATE OR REPLACE PIPE "EDL_DEV_SILVER"."RELTIO_SNOWFLAKE_SCHEMA"."RELTIO_SNOWFLAKE_PIPE"
   auto_ingest=true
   integration='RELTIO_SNOWFLAKE_NOTIFY_INT'
   AS
   COPY INTO "EDL_DEV_SILVER"."RELTIO_SNOWFLAKE_SCHEMA"."RELTIO_SNOWFLAKE_LANDING_TBL"
   FROM (
       SELECT $1:uri::string, $1:version::string, $1:timestamp::string,
              $1:deleted::boolean, $1:linked::boolean, $1:objectType::string,
              $1:type::string, $1, current_timestamp()
       FROM @"EDL_DEV_SILVER"."RELTIO_SNOWFLAKE_SCHEMA"."RELTIO_SNOWFLAKE_EXT_STG"
   )
   file_format = EDL_DEV_SILVER.RELTIO_SNOWFLAKE_SCHEMA.reltio_snowflake_json_fmt;
   

3. In the SQL worksheet, view the Successfully created notification message.