샘플 동기 Lambda Function¶

이 항목에는 있는 그대로 사용하여 첫 번째 외부 함수를 만들거나 사용자 지정 Lambda Function의 시작점으로 사용할 수 있는 샘플 Lambda Function의 코드가 포함됩니다.

이 함수는 동기식입니다.

(별개의 비동기 예 도 제공됩니다.)

이 예는 Python으로 작성되었습니다.

이 항목의 내용:

이 샘플 동기 Lambda Function은 각 행을 추출하여 처리하고 해당 행의 값을 반환합니다. 각 출력값은 단순히 입력 행에 있는 각 값의 복사본을 포함하는 배열입니다. 반환되는 배열은 Snowflake에서 SQL VARIANT로 처리됩니다.

import json

def lambda_handler(event, context):

    # 200 is the HTTP status code for "ok".
    status_code = 200

    # The return value will contain an array of arrays (one inner array per input row).
    array_of_rows_to_return = [ ]

    try:
        # From the input parameter named "event", get the body, which contains
        # the input rows.
        event_body = event["body"]

        # Convert the input from a JSON string into a JSON object.
        payload = json.loads(event_body)
        # This is basically an array of arrays. The inner array contains the
        # row number, and a value for each parameter passed to the function.
        rows = payload["data"]

        # For each input row in the JSON object...
        for row in rows:
            # Read the input row number (the output row number will be the same).
            row_number = row[0]

            # Read the first input parameter's value. For example, this can be a
            # numeric value or a string, or it can be a compound value such as
            # a JSON structure.
            input_value_1 = row[1]

            # Read the second input parameter's value.
            input_value_2 = row[2]

            # Compose the output based on the input. This simple example
            # merely echoes the input by collecting the values into an array that
            # will be treated as a single VARIANT value.
            output_value = ["Echoing inputs:", input_value_1, input_value_2]

            # Put the returned row number and the returned value into an array.
            row_to_return = [row_number, output_value]

            # ... and add that array to the main array.
            array_of_rows_to_return.append(row_to_return)

        json_compatible_string_to_return = json.dumps({"data" : array_of_rows_to_return})

    except Exception as err:
        # 400 implies some type of error.
        status_code = 400
        # Tell caller what this function could not handle.
        json_compatible_string_to_return = event_body

    # Return the return value and HTTP status code.
    return {
        'statusCode': status_code,
        'body': json_compatible_string_to_return
    }

Copy