카테고리:: 시스템 함수 (시스템 정보)

SYSTEM$SET_RETURN_VALUE¶

작업의 반환 값을 명시적으로 설정합니다.

작업 그래프 에서 작업은 이 함수를 호출하여 반환 값을 설정할 수 있습니다. 이 작업을 선행 작업으로 식별하는 다른 작업(작업 정의에서 AFTER 키워드 사용)은 SYSTEM$GET_PREDECESSOR_RETURN_VALUE 를 사용해 선행 작업이 설정한 반환 값을 검색할 수 있습니다.

구문¶

SYSTEM$SET_RETURN_VALUE( '<string_expression>' )

string_expression 인자의 값은 문자열 리터럴 또는 변수일 수 있습니다(예: SYSTEM$SET_RETURN_VALUE(:VARIABLE)).

인자¶

string_expression: 반환 값으로 설정할 문자열입니다. 문자열 크기는 10kB 이하여야 합니다(UTF8로 인코딩 시).

예¶

반환 값을 설정하는 작업을 만듭니다. 선행 작업이 완료된 후 실행되는 두 번째 하위 작업을 만듭니다. 하위 작업은 (SYSTEM$GET_PREDECESSOR_RETURN_VALUE 호출을 통해) 선행 작업에서 설정한 반환 값을 검색하여 테이블 행에 삽입합니다.

-- Create a table to store the return values.
CREATE OR REPLACE TABLE return_values_table (str VARCHAR);

-- Create a task that sets the return value for the task.
CREATE TASK set_return_value_task
  WAREHOUSE = return_task_wh
  SCHEDULE = '1 MINUTE'
  AS
    CALL SYSTEM$SET_RETURN_VALUE('The quick brown fox jumps over the lazy dog');

-- Create a task that identifies the first task as the predecessor task and retrieves the return value set for that task.
CREATE TASK get_return_value_task
  WAREHOUSE = return_task_wh
  AFTER set_return_value_task
  AS
    INSERT INTO return_values_table VALUES(SYSTEM$GET_PREDECESSOR_RETURN_VALUE());


-- Note that if there are multiple predecessor tasks that are enabled, you must specify the name of the task to retrieve the return value for that task.
CREATE TASK get_return_value_by_pred_task
  WAREHOUSE = return_task_wh
  AFTER set_return_value_task
  AS
    INSERT INTO return_values_table VALUES(SYSTEM$GET_PREDECESSOR_RETURN_VALUE('get_return_value_task'));

-- Resume task (using ALTER TASK ... RESUME).
-- Wait for task to run on schedule.

SELECT DISTINCT(str) FROM return_values_table;
+-----------------------------------------------+
|                      STR                      |
+-----------------------------------------------+
|  The quick brown fox jumps over the lazy dog  |
+-----------------------------------------------+

SELECT DISTINCT(RETURN_VALUE)
  FROM TABLE(information_schema.task_history())
  WHERE RETURN_VALUE IS NOT NULL;


+-----------------------------------------------+
|                  RETURN_VALUE                 |
+-----------------------------------------------+
|  The quick brown fox jumps over the lazy dog  |
+-----------------------------------------------+

예 2: 별도의 저장 프로시저를 사용하여 호출하기¶

첫 번째 예와 유사하지만, 작업에 대한 반환 값을 설정하고 별도의 저장 프로시저를 호출하여 검색합니다.

-- Create a table to store the return values.
CREATE OR REPLACE TABLE return_values_sp (str VARCHAR);

-- Create a stored procedure that sets the return value for the task.
CREATE OR REPLACE PROCEDURE set_return_value_sp()
RETURNS STRING
LANGUAGE JAVASCRIPT
EXECUTE AS CALLER
AS $$
var stmt = snowflake.createStatement({sqlText:`CALL SYSTEM$SET_RETURN_VALUE('The quick brown fox jumps over the lazy dog');`});
  var res = stmt.execute();
$$;

-- Create a stored procedure that inserts the return value for the predecessor task into the 'return_values_sp' table.
CREATE OR REPLACE PROCEDURE get_return_value_sp()
RETURNS STRING
LANGUAGE JAVASCRIPT
EXECUTE AS CALLER
AS $$
var stmt = snowflake.createStatement({sqlText:`INSERT INTO return_values_sp VALUES(SYSTEM$GET_PREDECESSOR_RETURN_VALUE());`});
var res = stmt.execute();
$$;

-- Create a task that calls the set_return_value_sp stored procedure.
CREATE TASK set_return_value_t
WAREHOUSE=warehouse1
SCHEDULE='1 MINUTE'
AS
  CALL set_return_value_sp();

-- Create a task that calls the get_return_value stored procedure.
CREATE TASK get_return_value_t
WAREHOUSE=warehouse1
AFTER set_return_value_t
AS
  CALL get_return_value_sp();

-- Resume task.
-- Wait for task to run on schedule.

SELECT DISTINCT(str) FROM return_values_sp;
+-----------------------------------------------+
|                      STR                      |
+-----------------------------------------------+
|  The quick brown fox jumps over the lazy dog  |
+-----------------------------------------------+

SELECT DISTINCT(RETURN_VALUE)
  FROM TABLE(information_schema.task_history())
  WHERE RETURN_VALUE IS NOT NULL;

+-----------------------------------------------+
|                  RETURN_VALUE                 |
+-----------------------------------------------+
|  The quick brown fox jumps over the lazy dog  |
+-----------------------------------------------+

예 3: 변수를 사용하여 반환 값 설정하기¶

다음 예에서는 작업 실행에 따라 반환 값을 동적으로 생성하고 변수를 사용하여 반환 값을 설정하는 방법을 보여줍니다. 이 예에서 작업은 스트림에서 랜딩 테이블로 데이터를 로딩하고 로딩된 행 수를 나타내는 반환 값을 설정합니다.

CREATE OR REPLACE TASK load_raw_data
WAREHOUSE = 'WH'
WHEN
    SYSTEM$STREAM_HAS_DATA('NEW_WEATHER_DATA')
AS
    DECLARE
        rows_loaded NUMBER;
        result_string VARCHAR;
    BEGIN
        INSERT INTO raw_weather_data ( -- our landing table
            row_id)
        SELECT
            row_id
        FROM
            new_weather_data  -- our source stream
        ;

        -- to see the number of rows loaded in the UI
        rows_loaded := (SELECT $1 FROM TABLE(RESULT_SCAN(LAST_QUERY_ID())));
        result_string := :rows_loaded || ' rows loaded into RAW_WEATHER_DATA';
        -- show result string as task return value
        CALL SYSTEM$SET_RETURN_VALUE(:result_string);
    END;