SYSTEM$SEND_SNOWFLAKE_NOTIFICATION으로 알림 보내기

SYSTEM$SEND_SNOWFLAKE_NOTIFICATION으로 알림 보내기 (Using SYSTEM$SEND_SNOWFLAKE_NOTIFICATION to send notifications)

이 문서는 SYSTEM$SEND_SNOWFLAKE_NOTIFICATION 시스템 함수를 사용해 Snowflake 알림을 보내는 방법을 설명해요.

출처: Using SYSTEM$SEND_SNOWFLAKE_NOTIFICATION to send notifications

본문

개요

SYSTEM$SEND_SNOWFLAKE_NOTIFICATION은 알림 통합(notification integration)을 사용해 알림을 보내는 Snowflake 시스템 함수예요. 이 함수는 이메일, 웹훅, 클라우드 메시징 서비스 등 통합 객체가 가리키는 대상에 알림을 전달해요.

이 함수는 태스크, 저장 프로시저, 외부 함수에서 호출할 수 있어요.

알림 통합 설정

SYSTEM$SEND_SNOWFLAKE_NOTIFICATION을 사용하려면 대상 유형에 맞는 알림 통합이 필요해요. 예를 들어 웹훅 또는 클라우드 메시징 서비스에 보내는 통합을 만들어요:

CREATE NOTIFICATION INTEGRATION my_integration
  TYPE = QUEUE
  ENABLED = TRUE
  NOTIFICATION_PROVIDER = AWS_SNS
  DIRECTION = OUTBOUND
  AWS_SNS_TOPIC_ARN = 'arn:aws:sns:us-west-2:123456789012:my-topic';

통합 유형별 자세한 설정은 관련 문서를 참고하세요:

SYSTEM$SEND_SNOWFLAKE_NOTIFICATION 사용

함수를 호출해 알림을 보내요:

SELECT SYSTEM$SEND_SNOWFLAKE_NOTIFICATION(
  'my_integration',
  '알림 메시지 내용'
);

함수 시그니처:

SYSTEM$SEND_SNOWFLAKE_NOTIFICATION(
  <integration_name>,
  <message>
)

<integration_name>: 알림 통합의 이름.
<message>: 보낼 알림 메시지.

반환 값

함수는 성공 여부를 나타내는 값을 반환해요. 반환 값을 확인해 알림이 제대로 전송되었는지 검증할 수 있어요.

태스크·프로시저에서 사용

태스크나 저장 프로시저 안에서 호출해 파이프라인 이벤트를 알릴 수 있어요. 예:

CREATE OR REPLACE PROCEDURE notify_team()
RETURNS BOOLEAN
LANGUAGE SQL
AS
$$
  SELECT SYSTEM$SEND_SNOWFLAKE_NOTIFICATION(
    'my_integration',
    '데이터 로드 완료'
  );
$$
;

제한 사항

알림 통합이 올바르게 구성·활성화되어 있어야 해요.
메시지가 전송되는 대상은 통합 유형에 따라 달라져요.
Snowflake 요금 체계에 따라 알림 전송량에 요금이 부과될 수 있어요.

SYSTEM$SEND_SNOWFLAKE_NOTIFICATION으로 알림 보내기