예산에 대한 주기 시작 작업¶

저장 프로시저 요구 사항¶

주기 시작 작업에 의해 호출되는 저장 프로시저는 다음 요구 사항을 충족해야 합니다.

• 프로시저는 호출자의 권한이 아닌 소유자의 권한으로 실행해야 합니다. 자세한 내용은 호출자 권한 및 소유자 권한 저장 프로시저 이해하기 섹션을 참조하십시오.

• 프로시저를 완료하는 데는 30분 이상 소요될 수 없습니다.

• 프로시저에는 OUTPUT 인자가 포함될 수 없습니다.

• 중복되거나 의도하지 않은 결과를 초래하지 않고 여러 번 호출되는 것을 처리하도록 프로시저를 설계합니다.

• 프로시저의 필수 인자는 다음 데이터 타입 중 하나여야 합니다.

  • 숫자 데이터 타입

  • 문자열 및 이진 데이터 타입

  • 논리 데이터 타입

  • 날짜 및 시간 데이터 타입

이러한 요구 사항을 충족하는 저장 프로시저를 생성한 후에는 프로시저 및 해당 상위 데이터베이스와 스키마에 대한 SNOWFLAKE 애플리케이션 USAGE 권한을 부여해야 합니다. 예를 들어, 저장 프로시저의 정규화된 이름이 ``code_db.sch1.reset_resources``인 경우 다음 명령을 실행합니다.

GRANT USAGE ON DATABASE code_db TO APPLICATION SNOWFLAKE;
GRANT USAGE ON SCHEMA code_db.sch1 TO APPLICATION SNOWFLAKE;
GRANT USAGE ON PROCEDURE code_db.sch1.reset_resources(STRING, STRING) TO APPLICATION SNOWFLAKE;

예산에 대한 주기 시작 작업 설정¶

예산(계정 예산 또는 사용자 지정 예산)당 하나의 주기 시작 작업을 설정할 수 있습니다. 주기 시작 작업은 다음 구성 요소로 구성됩니다.

• 저장 프로시저: 예산 주기가 다시 시작될 때 호출될 프로시저에 대한 참조입니다.

• 인자: 저장 프로시저에 전달할 인자의 배열입니다.

예산에 대한 주기 시작 작업을 설정하려면 예산 인스턴스에서 SET_CYCLE_START_ACTION 메서드를 호출합니다. 예를 들어, 다음 코드는 예산 주기가 다시 시작될 때 reset_resources 저장 프로시저를 호출하는 주기 시작 작업을 설정합니다.

CALL budget_db.sch1.my_budget!SET_CYCLE_START_ACTION(
  SYSTEM$REFERENCE('PROCEDURE', 'code_db.sch1.reset_resources(STRING, STRING, STRING, STRING)'),
  ARRAY_CONSTRUCT('my_int', 'admin@example.com', 'Budget Alert', 'New budget cycle started'));

주기 시작 작업에 의해 호출되는 저장 프로시저 생성을 포함하는 전체 예제는 확장된 예 섹션을 참조하세요.

예산에서 주기 시작 작업 제거¶

예산에 대한 주기 시작 작업을 제거하려면 예산 인스턴스에서 REMOVE_CYCLE_START_ACTION 메서드를 호출합니다.

CALL budget_db.sch1.my_budget!REMOVE_CYCLE_START_ACTION();

확장된 예¶

다음 예제에서는 주기 시작 작업으로 호출되는 저장 프로시저를 작성하고, 프로시저에 필요한 권한을 부여한 다음, 예산에 대한 주기 시작 작업을 설정하는 방법을 보여줍니다.

1. :ref:`모든 요구 사항을 준수 <label-budget_cycle_start_actions_stored_procedure>`하는 저장 프로시저를 생성합니다.

   CREATE OR REPLACE PROCEDURE code_db.sch1.reset_resources(
       integration_name STRING,
       email_list STRING,
       email_subject STRING,
       email_content STRING)
   RETURNS STRING
   LANGUAGE JAVASCRIPT
   EXECUTE AS OWNER
   AS
   $$
       // Re-enable warehouses or reset configurations here
       var enable_wh = "ALTER WAREHOUSE my_warehouse RESUME;";
       var statement1 = snowflake.createStatement({sqlText: enable_wh});
       statement1.execute();
   
       // Send notification about new cycle
       var sql_command = "CALL SYSTEM$SEND_EMAIL('" + INTEGRATION_NAME + "', " +
                                               "'" + EMAIL_LIST + "', " +
                                               "'" + EMAIL_SUBJECT + "'," +
                                               "'" + EMAIL_CONTENT + "'" + ");";
       var statement2 = snowflake.createStatement({sqlText: sql_command});
       statement2.execute();
       return "Resources reset for new budget cycle";
   $$;
   

   Copy

2. SNOWFLAKE 애플리케이션에 저장 프로시저에 대한 권한을 부여합니다.

   GRANT USAGE ON DATABASE code_db TO APPLICATION SNOWFLAKE;
   GRANT USAGE ON SCHEMA code_db.sch1 TO APPLICATION SNOWFLAKE;
   GRANT USAGE ON PROCEDURE code_db.sch1.reset_resources(STRING, STRING, STRING, STRING)
     TO APPLICATION SNOWFLAKE;
   

   Copy

3. 예산에 대한 주기 시작 작업을 설정합니다.

   CALL budget_db.sch1.my_budget!SET_CYCLE_START_ACTION(
     SYSTEM$REFERENCE('PROCEDURE', 'code_db.sch1.reset_resources(STRING, STRING, STRING, STRING)'),
     ARRAY_CONSTRUCT('my_int', 'admin@example.com', 'Budget Cycle Restarted', 'New budget cycle has begun'));
   

   Copy

주기 시작 작업 문제 해결¶

주기 시작 작업이 예상대로 작동하지 않으면 다음 방법을 사용하여 문제를 진단합니다.

SELECT th.*, ci.name AS budget_name
  FROM SNOWFLAKE.ACCOUNT_USAGE.TASK_HISTORY th
  JOIN SNOWFLAKE.ACCOUNT_USAGE.CLASS_INSTANCES ci
    ON th.instance_id = ci.id
  WHERE ci.class_name = 'BUDGET'
    AND th.name ILIKE '_budget_cycle_start_task'
    AND ci.name = '<budget_name>'
  ORDER BY th.completed_time DESC
  LIMIT 10;

SHOW GRANTS ON PROCEDURE code_db.sch1.reset_resources(STRING, STRING, STRING, STRING);

CALL budget_db.sch1.my_budget!GET_CONFIG();

CALL budget_db.sch1.my_budget!GET_CYCLE_START_ACTION();