Azure Logic Apps 청크를 사용하여 워크플로에서 큰 메시지 처리

아티클
02/13/2024

적용 대상: Azure Logic Apps(소비)

Azure Logic Apps는 논리 앱 리소스 종류 및 논리 앱 워크플로가 실행되는 환경에 따라 트리거 및 작업이 논리 앱 워크플로에서 처리할 수 있는 메시지 콘텐츠 크기 최대 한도가 다릅니다. 이러한 제한은 큰 메시지를 저장하고 처리하여 발생하는 오버헤드를 줄이는 데 도움이 됩니다. 메시지 크기 제한에 대한 자세한 내용은 Message limits in Azure Logic Apps(Azure Logic Apps 메시지 제한)를 검토하세요.

기본 제공 HTTP 작업 또는 특정 관리형 커넥터 작업을 사용하고 있고 기본 제한보다 큰 메시지로 작업하기 위해 Azure Logic Apps가 필요한 경우 청크를 사용하여 큰 메시지를 더 작은 메시지로 분할할 수 있습니다. 그러면 특정 조건에 따라 큰 파일 보고서를 전송할 수도 있습니다. 실제로 이러한 기본 제공 HTTP 작업 또는 특정 관리형 커넥터 작업을 사용하는 경우 청크는 Azure Logic Apps가 큰 메시지를 이용할 수 있는 유일한 방법입니다. 이 요구 사항은 Azure Logic Apps 및 기타 서비스 간의 기본 HTTP 메시지 교환에서 청크를 사용해야 함을 의미하거나, 사용하려는 관리형 커넥터에서 만든 연결도 청크를 지원해야 함을 의미합니다.

참고 항목

Azure Logic Apps는 여러 메시지 교환으로 인한 오버헤드 증가로 인해 트리거에서 청크를 지원하지 않습니다. 또한 Azure Logic Apps는 이 문서에 설명된 대로 자체 프로토콜을 사용하여 HTTP 작업에 대한 청크를 구현합니다. 따라서 웹 사이트 또는 웹 서비스가 청크를 지원하더라도 HTTP 작업 청크에서는 작동하지 않습니다. 웹 사이트 또는 웹 서비스에서 HTTP 작업 청크를 사용하려면 Azure Logic Apps에서 사용하는 것과 동일한 프로토콜을 구현해야 합니다. 그렇지 않으면 HTTP 작업에서 청크를 사용하지 마세요.

이 문서에서는 Azure Logic Apps 청크가 작동하는 방식과 지원되는 작업에 청크를 설정하는 방법에 대한 개요를 제공합니다.

메시지를 "큰 메시지"로 만드는 요인은 무엇인가요?

이 경우 해당 메시지를 처리하는 서비스를 기반으로 하는 "큰 메시지"입니다. 큰 메시지의 정확한 크기 제한은 Logic Apps 및 커넥터에 따라 다릅니다. Logic Apps와 커넥터는 모두 큰 메시지를 직접 사용할 수 없으며, 큰 메시지는 청크 분할해야 합니다. Logic Apps 메시지 크기 제한은 Logic Apps 제한 및 구성을 참조하세요. 각 커넥터의 메시지 크기 제한은 커넥터의 참조 설명서를 참조하세요.

Logic Apps에 대한 청크 분할 메시지 처리

Logic Apps는 메시지 크기 제한보다 큰 청크 분할 메시지의 출력을 직접 사용할 수 없습니다. 청크 분할을 지원하는 작업만 이러한 출력의 메시지 콘텐츠에 액세스할 수 있습니다. 따라서 큰 메시지를 처리하는 작업은 다음 기준 중 하나를 충족해야 합니다.

해당 작업이 커넥터에 속한 경우 기본적으로 청크 분할을 지원합니다.
해당 작업의 런타임 구성에 사용하도록 설정된 청크 분할 지원이 있습니다.

그렇지 않으면 큰 콘텐츠 출력에 액세스하려고 할 때 런타임 오류가 발생합니다. 청크 분할을 사용하도록 설정하려면 청크 분할 지원 설정을 참조하세요.

커넥터에 대한 청크 분할 메시지 처리

Logic Apps와 통신하는 서비스에는 자체의 메시지 크기 제한이 있을 수 있습니다. 이러한 제한은 종종 Logic Apps 앱 제한보다 작습니다. 예를 들어 커넥터에서 청크 분할을 지원한다고 가정하면 커넥터는 30MB 메시지를 큰 메시지로 간주할 수 있지만 Logic Apps는 그렇지 않습니다. 이 커넥터의 제한을 준수하기 위해 Logic Apps는 30MB를 초과하는 모든 메시지를 더 작은 청크로 분할합니다.

청크 분할을 지원하는 커넥터의 경우 기본 청크 분할 프로토콜은 최종 사용자에게 표시되지 않습니다. 그러나 모든 커넥터에서 청크 분할을 지원하지 것은 아니기 때문에 들어오는 메시지가 커넥터의 크기 제한을 초과하면 이러한 커넥터에서 런타임 오류가 발생합니다.

청크 분할을 지원하고 사용하도록 설정된 작업에는 @triggerBody()?['Content']와 같은 트리거 본문, 변수, 식을 사용할 수 없습니다. 해당 입력을 사용하면 청크 분할 작업이 이루어지지 않습니다. 대신 작성 작업을 사용합니다. 특히 트리거 본문, 변수, 식 등의 데이터 출력을 저장하는 작성 작업을 사용하여 body 필드를 만들어야 합니다. 예를 들면 다음과 같습니다.

"Compose": {
    "inputs": {
        "body": "@variables('myVar1')"
    },
    "runAfter": {
        "Until": [
            "Succeeded"
        ]
    },
    "type": "Compose"
},

그런 다음, 청크 분할 작업에서 데이터를 참조하기 위해 @body('Compose')를 사용합니다.

"Create_file": {
    "inputs": {
        "body": "@body('Compose')",
        "headers": {
            "ReadFileMetadataFromServer": true
        },
        "host": {
            "connection": {
                "name": "@parameters('$connections')['sftpwithssh_1']['connectionId']"
            }
        },
        "method": "post",
        "path": "/datasets/default/files",
        "queries": {
            "folderPath": "/c:/test1/test1sub",
            "name": "tt.txt",
            "queryParametersSingleEncoded": true
        }
    },
    "runAfter": {
        "Compose": [
            "Succeeded"
        ]
    },
    "runtimeConfiguration": {
        "contentTransfer": {
            "transferMode": "Chunked"
        }
    },
    "type": "ApiConnection"
},

HTTP를 통한 청크 분할 설정

일반적인 HTTP 시나리오에서는 논리 앱과 엔드포인트에서 큰 메시지를 교환할 수 있도록 HTTP를 통해 큰 콘텐츠의 다운로드 및 업로드를 분할할 수 있습니다. 그러나 Logic Apps에 필요한 방식으로 메시지를 청크 분할해야 합니다.

엔드포인트에서 다운로드 또는 업로드에 대한 청크 분할을 사용하도록 설정한 경우 논리 앱의 HTTP 작업에서는 큰 메시지를 자동으로 청크 분할합니다. 그렇지 않으면 엔드포인트에서 청크 분할을 지원하도록 설정해야 합니다. 엔드포인트 또는 커넥터를 소유하거나 제어하지 않으면 청크 분할을 설정할 수 있는 옵션이 없을 수 있습니다.

또한 HTTP 작업에서 아직 청크 분할을 사용하도록 설정하지 않은 경우 작업의 runTimeConfiguration 속성에서 청크 분할을 설정해야 합니다. 이 속성은 작업 내에 설정할 수 있습니다. 나중에 설명하는 대로 코드 보기 편집기에서 직접 수행하거나, 여기서 설명하는 대로 논리 앱 디자이너에서 수행할 수 있습니다.

HTTP 작업의 오른쪽 위 모서리에서 줄임표 단추 (...)를 선택한 다음, 설정을 선택합니다.
콘텐츠 전송에서 청크 허용을 켜기로 설정합니다.
다운로드 또는 업로드에 대한 청크 분할 설정을 계속하려면 다음 섹션으로 계속 진행하세요.

청크로 콘텐츠 다운로드

많은 엔드포인트에서 HTTP GET 요청을 통해 다운로드할 때 큰 메시지를 청크로 자동으로 보냅니다. HTTP를 통해 엔드포인트에서 청크 분할 메시지를 다운로드하려면 엔드포인트에서 부분 콘텐츠 요청 또는 청크 분할 다운로드를 지원해야 합니다. 논리 앱에서 콘텐츠를 다운로드하기 위해 엔드포인트에 HTTP GET 요청을 보내고 엔드포인트에서 "206" 상태 코드로 응답하면, 응답에 청크 분할된 콘텐츠가 포함됩니다. Logic Apps는 엔드포인트에서 부분 요청을 지원하는지 여부를 제어할 수 없습니다. 그러나 논리 앱에서 첫 번째 "206" 응답을 받으면 논리 앱이 모든 콘텐츠를 다운로드하기 위해 여러 요청을 자동으로 보냅니다.

엔드포인트에서 부분 콘텐츠를 지원할 수 있는지 여부를 확인하려면 HEAD 요청을 보냅니다. 이 요청은 응답에 Accept-Ranges 헤더가 포함되어 있는지 여부를 결정하는 데 도움이 됩니다. 이러한 방식으로 엔드포인트에서 청크 분할 콘텐츠를 지원하지만 청크 분할 콘텐츠를 보내지 않으면, HTTP GET 요청에 Range 헤더를 설정하여 이 옵션을 제안할 수 있습니다.

다음 단계에서는 Logic Apps가 청크 분할 콘텐츠를 엔드포인트에서 논리 앱으로 다운로드하는 데 사용하는 자세한 프로세스를 설명합니다.

논리 앱에서 HTTP GET 요청을 엔드포인트에 보냅니다.

필요에 따라 요청 헤더에는 콘텐츠 청크를 요청하기 위한 바이트 범위를 설명하는 Range 필드가 포함될 수 있습니다.
엔드포인트는 "206" 상태 코드와 HTTP 메시지 본문으로 응답합니다.

이 청크의 콘텐츠에 대한 세부 정보는 Logic Apps에서 청크의 시작과 끝을 결정하는 데 도움이 되는 정보와 청크 이전 전체 콘텐츠의 총 크기를 포함하여 응답의 Content-Range 헤더에 표시됩니다.
논리 앱에서 후속 HTTP GET 요청을 자동으로 보냅니다.

논리 앱에서는 전체 콘텐츠를 검색할 때까지 후속 GET 요청을 보냅니다.

예를 들어 다음 작업 정의에서는 Range 헤더를 설정하는 HTTP GET 요청을 보여 줍니다. 헤더는 엔드포인트에서 청크 분할 콘텐츠로 응답해야 한다고 제안합니다.

"getAction": {
    "inputs": {
        "headers": {
            "Range": "bytes=0-1023"
        },
       "method": "GET",
       "uri": "http://myAPIendpoint/api/downloadContent"
    },
    "runAfter": {},
    "type": "Http"
}

GET 요청은 "Range" 헤더를 바이트 범위인 "bytes=0-1023"으로 설정합니다. 엔드포인트에서 부분 콘텐츠 요청을 지원하면, 엔드포인트는 요청된 범위의 콘텐츠 청크로 응답합니다. 엔드포인트에 따라 "Range" 헤더 필드에 대한 정확한 형식이 다를 수 있습니다.

청크로 콘텐츠 업로드

HTTP 작업에서 청크 분할 콘텐츠를 업로드하려면 작업의 runtimeConfiguration 속성을 통해 청크 분할 지원을 사용하도록 설정되어 있어야 합니다. 이 설정을 통해 작업에서 청크 분할 프로토콜을 시작할 수 있습니다. 그런 다음, 논리 앱에서 초기 POST 또는 PUT 메시지를 대상 엔드포인트에 보낼 수 있습니다. 엔드포인트에서 제안된 청크 크기로 응답하면 논리 앱에서 콘텐츠 청크가 포함된 HTTP PATCH 요청을 보내서 처리합니다.

다음 단계에서는 Logic Apps가 청크 분할 콘텐츠를 논리 앱에서 엔드포인트로 업로드하는 데 사용하는 세부 프로세스형을 설명합니다.

논리 앱에서 빈 메시지 본문이 있는 초기 HTTP POST 또는 PUT 요청을 보냅니다. 요청 헤더에는 논리 앱에서 청크로 업로드하려는 콘텐츠에 대한 다음 정보가 포함됩니다.

Logic Apps 요청 헤더 필드	값	Type	설명
x-ms-transfer-mode	chunked	문자열	콘텐츠가 청크로 업로드됨을 나타냅니다.
x-ms-content-length	<content-length>	정수	청크 분할 이전의 전체 콘텐츠 크기(바이트)입니다.

엔드포인트에서 "200" 성공 상태 코드와 다음의 정보로 응답합니다.

엔드포인트 응답 헤더 필드	Type	필수	설명
위치	문자열	예	HTTP PATCH 메시지를 보낼 URL 위치입니다.
x-ms-chunk-size	정수	아니요	제안된 청크 크기(바이트)입니다.

논리 앱에서 각각 다음 정보가 포함된 후속 HTTP PATCH 메시지를 만들어 보냅니다.

x-ms-chunk-size 또는 총 x-ms-content-length 크기의 모든 콘텐츠가 순차적으로 업로드될 때까지 일부 내부적으로 계산된 크기 기준의 콘텐츠 청크

각 PATCH 메시지에 전송되는 콘텐츠 청크에 대한 다음과 같은 헤더 정보:

Logic Apps 요청 헤더 필드	값	Type	설명
Content-Range	<range>	문자열	시작 값, 끝 값 및 전체 콘텐츠 크기를 포함하여 현재 콘텐츠 청크에 대한 바이트 범위입니다(예: "bytes=0-1023/10100").
Content-Type	<content-type>	문자열	청크 분할 콘텐츠의 형식입니다.
Content-Length	<content-length>	문자열	현재 청크의 길이(바이트 크기)입니다.

각 PATCH 요청 후에는 엔드포인트에서 "200" 상태 코드와 다음 응답 헤더로 응답하여 각 청크에 대한 수신을 확인합니다.

엔드포인트 응답 헤더 필드	Type	필수	설명
범위	문자열	예	엔드포인트에서 받은 콘텐츠의 바이트 범위입니다(예: "bytes=0-1023")입니다.
x-ms-chunk-size	정수	아니요	제안된 청크 크기(바이트)입니다.

예를 들어 다음 작업 정의에서는 청크 분할 콘텐츠를 엔드포인트에 업로드하기 위한 HTTP POST 요청을 보여 줍니다. 작업의 runTimeConfiguration 속성에서 contentTransfer 속성은 transferMode를 chunked로 설정합니다.

"postAction": {
    "runtimeConfiguration": {
        "contentTransfer": {
            "transferMode": "chunked"
        }
    },
    "inputs": {
        "method": "POST",
        "uri": "http://myAPIendpoint/api/action",
        "body": "@body('getAction')"
    },
    "runAfter": {
    "getAction": ["Succeeded"]
    },
    "type": "Http"
}

다음을 통해 공유