CREATE NOTIFICATION INTEGRATION(Google Pub/Sub ํ•ญ๋ชฉ์—์„œ ์ธ๋ฐ”์šด๋“œ)ยถ

Google Pub/Sub ํ•ญ๋ชฉ์—์„œ ๋ฉ”์‹œ์ง€๋ฅผ ์ˆ˜์‹ ํ•˜๊ธฐ ์œ„ํ•ด ๊ณ„์ •์— ์ƒˆ ์•Œ๋ฆผ ํ†ตํ•ฉ์„ ๋งŒ๋“ค๊ฑฐ๋‚˜ ๊ธฐ์กด ํ†ตํ•ฉ์„ ๋ฐ”๊ฟ‰๋‹ˆ๋‹ค.

์ฐธ๊ณ  ํ•ญ๋ชฉ:

ALTER NOTIFICATION INTEGRATION(Google Pub/Sub ํ•ญ๋ชฉ์—์„œ ์ธ๋ฐ”์šด๋“œ) , DESCRIBE NOTIFICATION INTEGRATION , DROP INTEGRATION , SHOW NOTIFICATION INTEGRATIONS

๊ตฌ๋ฌธยถ

CREATE [ OR REPLACE ] NOTIFICATION INTEGRATION [ IF NOT EXISTS ] <name>
  ENABLED = { TRUE | FALSE }
  TYPE = QUEUE
  NOTIFICATION_PROVIDER = GCP_PUBSUB
  GCP_PUBSUB_SUBSCRIPTION_NAME = '<subscription_id>'
  [ COMMENT = '<string_literal>' ]
Copy

ํ•„์ˆ˜ ๋งค๊ฐœ ๋ณ€์ˆ˜ยถ

name

ํ†ตํ•ฉ์— ๋Œ€ํ•œ ์‹๋ณ„์ž(์ฆ‰, ์ด๋ฆ„)๋ฅผ ์ง€์ •ํ•˜๋Š” ๋ฌธ์ž์—ด๋กœ, ๊ณ„์ •์—์„œ ๊ณ ์œ ํ•ด์•ผ ํ•ฉ๋‹ˆ๋‹ค.

๋˜ํ•œ, ์‹๋ณ„์ž๋Š” ์•ŒํŒŒ๋ฒณ ๋ฌธ์ž๋กœ ์‹œ์ž‘ํ•ด์•ผ ํ•˜๋ฉฐ ์ „์ฒด ์‹๋ณ„์ž ๋ฌธ์ž์—ด์„ ํฐ๋”ฐ์˜ดํ‘œ(์˜ˆ: "My object")๋กœ ๋ฌถ์ง€ ์•Š๋Š” ํ•œ ๊ณต๋ฐฑ์ด๋‚˜ ํŠน์ˆ˜ ๋ฌธ์ž๋ฅผ ํฌํ•จํ•  ์ˆ˜ ์—†์Šต๋‹ˆ๋‹ค. ํฐ๋”ฐ์˜ดํ‘œ๋กœ ๋ฌถ์ธ ์‹๋ณ„์ž๋„ ๋Œ€/์†Œ๋ฌธ์ž๋ฅผ ๊ตฌ๋ถ„ํ•ฉ๋‹ˆ๋‹ค.

์ž์„ธํ•œ ๋‚ด์šฉ์€ ์‹๋ณ„์ž ์š”๊ตฌ ์‚ฌํ•ญ ์„น์…˜์„ ์ฐธ์กฐํ•˜์‹ญ์‹œ์˜ค.

ENABLED = { TRUE | FALSE }

ํ†ตํ•ฉ ์ž‘์—…์„ ์‹œ์ž‘ํ• ์ง€ ์ผ์‹œ ์ค‘๋‹จํ• ์ง€ ์—ฌ๋ถ€๋ฅผ ์ง€์ •ํ•ฉ๋‹ˆ๋‹ค.

  • TRUE ๋กœ ์ง€์ •ํ•˜๋ฉด ํ†ตํ•ฉ์ด ํ™œ์„ฑํ™”๋ฉ๋‹ˆ๋‹ค.

  • FALSE ๋กœ ์ง€์ •ํ•˜๋ฉด ์œ ์ง€ ๊ด€๋ฆฌ๋ฅผ ์œ„ํ•ด ํ†ตํ•ฉ์ด ๋น„ํ™œ์„ฑํ™”๋ฉ๋‹ˆ๋‹ค. Snowflake์™€ ์„œ๋“œ ํŒŒํ‹ฐ ์„œ๋น„์Šค ๊ฐ„์˜ ํ†ตํ•ฉ์ด ์ž‘๋™ํ•˜์ง€ ์•Š์Šต๋‹ˆ๋‹ค.

TYPE = QUEUE

์ด๋Š” Snowflake์™€ ์„œ๋“œ ํŒŒํ‹ฐ ํด๋ผ์šฐ๋“œ ๋ฉ”์‹œ์ง€ ํ ์„œ๋น„์Šค ๊ฐ„์˜ ํ†ตํ•ฉ์ž„์„ ์ง€์ •ํ•ฉ๋‹ˆ๋‹ค.

NOTIFICATION_PROVIDER = GCP_PUBSUB

Google Cloud Pub/Sub๋ฅผ ์„œ๋“œ ํŒŒํ‹ฐ ํด๋ผ์šฐ๋“œ ๋ฉ”์‹œ์ง€ ํ ์„œ๋น„์Šค๋กœ ์ง€์ •ํ•ฉ๋‹ˆ๋‹ค.

GCP_PUBSUB_SUBSCRIPTION_NAME = 'subscription_id'

Snowflake๊ฐ€ ์ด๋ฒคํŠธ ๋ฉ”์‹œ์ง€์— ์•ก์„ธ์Šคํ•  ์ˆ˜ ์žˆ๋„๋ก ํ—ˆ์šฉํ•˜๋Š” ๋ฐ ์‚ฌ์šฉ๋˜๋Š” Pub/Sub ํ•ญ๋ชฉ ๊ตฌ๋… ID์ž…๋‹ˆ๋‹ค.

์ฐธ๊ณ 

๋‹จ์ผ ์•Œ๋ฆผ ํ†ตํ•ฉ์€ ๋‹จ์ผ Google Cloud Pub/Sub ๊ตฌ๋…์„ ์ง€์›ํ•ฉ๋‹ˆ๋‹ค. ์ด๋ฒคํŠธ ์•Œ๋ฆผ์€ ์•Œ๋ฆผ ํ†ตํ•ฉ ์‚ฌ์ด์—์„œ ๋ถ„ํ• ๋˜๋ฏ€๋กœ ์—ฌ๋Ÿฌ ์•Œ๋ฆผ ํ†ตํ•ฉ์—์„œ ๋™์ผํ•œ Pub/Sub ๊ตฌ๋…์„ ์ฐธ์กฐํ•˜๋ฉด ๋Œ€์ƒ ํ…Œ์ด๋ธ”์—์„œ ๋ฐ์ดํ„ฐ๊ฐ€ ๋ˆ„๋ฝ๋  ์ˆ˜ ์žˆ์Šต๋‹ˆ๋‹ค.

์„ ํƒ์  ๋งค๊ฐœ ๋ณ€์ˆ˜ยถ

COMMENT = 'string_literal'

ํ†ตํ•ฉ์— ๋Œ€ํ•œ ์„ค๋ช…์„ ์ง€์ •ํ•˜๋Š” ๋ฌธ์ž์—ด(๋ฆฌํ„ฐ๋Ÿด)์ž…๋‹ˆ๋‹ค.

๊ธฐ๋ณธ๊ฐ’: ๊ฐ’ ์—†์Œ

์•ก์„ธ์Šค ์ œ์–ด ์š”๊ตฌ ์‚ฌํ•ญยถ

์ด ์ž‘์—…์„ ์‹คํ–‰ํ•˜๋Š” ๋ฐ ์‚ฌ์šฉ๋˜๋Š” ์—ญํ•  ์—๋Š” ์ตœ์†Œํ•œ ๋‹ค์Œ ๊ถŒํ•œ ์ด ์žˆ์–ด์•ผ ํ•ฉ๋‹ˆ๋‹ค.

๊ถŒํ•œ

์˜ค๋ธŒ์ ํŠธ

์ฐธ๊ณ 

CREATE INTEGRATION

๊ณ„์ •

Only the ACCOUNTADMIN role has this privilege by default. The privilege can be granted to additional roles as needed.

์ง€์ •๋œ ๊ถŒํ•œ ์„ธํŠธ๋กœ ์‚ฌ์šฉ์ž ์ง€์ • ์—ญํ• ์„ ๋งŒ๋“œ๋Š” ๋ฐฉ๋ฒ•์— ๋Œ€ํ•œ ์ง€์นจ์€ ์‚ฌ์šฉ์ž ์ง€์ • ์—ญํ•  ๋งŒ๋“ค๊ธฐ ์„น์…˜์„ ์ฐธ์กฐํ•˜์‹ญ์‹œ์˜ค.

๋ณด์•ˆ ์˜ค๋ธŒ์ ํŠธ ์— ๋Œ€ํ•ด SQL ์ž‘์—…์„ ์ˆ˜ํ–‰ํ•˜๊ธฐ ์œ„ํ•œ ์—ญํ• ๊ณผ ๊ถŒํ•œ ๋ถ€์—ฌ์— ๋Œ€ํ•œ ์ผ๋ฐ˜์ ์ธ ์ •๋ณด๋Š” ์•ก์„ธ์Šค ์ œ์–ด์˜ ๊ฐœ์š” ์„น์…˜์„ ์ฐธ์กฐํ•˜์‹ญ์‹œ์˜ค.

์‚ฌ์šฉ๋ฒ• ๋…ธํŠธยถ

  • ์—ฌ๋Ÿฌ Google Cloud Pub/Sub ๊ตฌ๋…์— ๋Œ€ํ•œ ๋‹จ์ผ ์•Œ๋ฆผ ํ†ตํ•ฉ ๋งŒ๋“ค๊ธฐ๋Š” ์ง€์›๋˜์ง€ ์•Š์Šต๋‹ˆ๋‹ค.

    ๋‹ค๋ฅธ ์•Œ๋ฆผ ํ†ตํ•ฉ๊ณผ ๋™์ผํ•œ ํ URL์ด ์žˆ๋Š” ์•Œ๋ฆผ ํ†ตํ•ฉ์„ ์‚ฌ์šฉํ•˜์—ฌ ์ƒˆ ํŒŒ์ดํ”„๋ฅผ ์ƒ์„ฑํ•  ๋•Œ ํŒŒ์ดํ”„ ์ƒ์„ฑ์ด ์˜ค๋ฅ˜ ๋ฐœ์ƒ์œผ๋กœ ์‹คํŒจํ•ฉ๋‹ˆ๋‹ค.

    Notification queue already in use with another integration.
    
  • ์—ฌ๋Ÿฌ ์ธ๋ฐ”์šด๋“œ ์•Œ๋ฆผ ํ†ตํ•ฉ์— ๋™์ผํ•œ Google Cloud Pub/Sub ๊ตฌ๋…์„ ์‚ฌ์šฉํ•˜๋Š” ๊ฒƒ์€ ์ž๋™ํ™”๋œ ๋ฐ์ดํ„ฐ ๋กœ๋“œ ๋˜๋Š” ๋ฉ”ํƒ€๋ฐ์ดํ„ฐ ์ƒˆ๋กœ ๊ณ ์นจ์— ์ง€์›๋˜์ง€ ์•Š์Šต๋‹ˆ๋‹ค.

  • ๋ฉ”ํƒ€๋ฐ์ดํ„ฐ ๊ด€๋ จ:

    ์ฃผ์˜

    ๊ณ ๊ฐ์€ Snowflake ์„œ๋น„์Šค๋ฅผ ์‚ฌ์šฉํ•  ๋•Œ ๊ฐœ์ธ ๋ฐ์ดํ„ฐ(์‚ฌ์šฉ์ž ์˜ค๋ธŒ์ ํŠธ ์ œ์™ธ), ๋ฏผ๊ฐํ•œ ๋ฐ์ดํ„ฐ, ์ˆ˜์ถœ ํ†ต์ œ ๋Œ€์ƒ ๋ฐ์ดํ„ฐ ๋˜๋Š” ๊ธฐํƒ€ ๊ทœ์ œ ๋ฐ์ดํ„ฐ๊ฐ€ ๋ฉ”ํƒ€๋ฐ์ดํ„ฐ๋กœ ์ž…๋ ฅ๋˜์ง€ ์•Š๋„๋ก ํ•ด์•ผ ํ•ฉ๋‹ˆ๋‹ค. ์ž์„ธํ•œ ๋‚ด์šฉ์€ Snowflake์˜ ๋ฉ”ํƒ€๋ฐ์ดํ„ฐ ํ•„๋“œ ์„น์…˜์„ ์ฐธ์กฐํ•˜์‹ญ์‹œ์˜ค.

  • OR REPLACE ๋ฐ IF NOT EXISTS ์ ˆ์€ ์ƒํ˜ธ ๋ฐฐํƒ€์ ์ž…๋‹ˆ๋‹ค. ๋‘ ๋ฌธ์ž๋ฅผ ๊ฐ™์€ ๋ฌธ์— ํ•จ๊ป˜ ์‚ฌ์šฉํ•  ์ˆ˜ ์—†์Šต๋‹ˆ๋‹ค.

  • CREATE OR REPLACE <์˜ค๋ธŒ์ ํŠธ> ๋ฌธ์€ ์›์ž์„ฑ์ž…๋‹ˆ๋‹ค. ์ฆ‰, ์˜ค๋ธŒ์ ํŠธ๊ฐ€ ๋ฐ”๋€” ๋•Œ ๋‹จ์ผ ํŠธ๋žœ์žญ์…˜์œผ๋กœ ์ด์ „ ์˜ค๋ธŒ์ ํŠธ๊ฐ€ ์‚ญ์ œ๋˜๊ณ  ์ƒˆ ์˜ค๋ธŒ์ ํŠธ๊ฐ€ ์ƒ์„ฑ๋ฉ๋‹ˆ๋‹ค.

  • ํด๋ผ์šฐ๋“œ ๊ณต๊ธ‰์ž์˜ ์ •๋ถ€ ๋ฆฌ์ „์—์„œ๋Š” ์ด๋ฒคํŠธ ์•Œ๋ฆผ์ด ๋‹ค๋ฅธ ์ƒ์—… ๋ฆฌ์ „์œผ๋กœ ์ „์†ก๋˜๊ฑฐ๋‚˜ ๋‹ค๋ฅธ ์ƒ์—… ๋ฆฌ์ „์—์„œ ์ „์†ก๋˜๋Š” ๊ฒƒ์„ ํ—ˆ์šฉํ•˜์ง€ ์•Š์Šต๋‹ˆ๋‹ค.

์˜ˆยถ

๋‹ค์Œ ํ•ญ๋ชฉ์„ ์ฐธ์กฐํ•˜์‹ญ์‹œ์˜ค.