Gestire messaggi di grandi dimensioni nei flussi di lavoro usando la suddivisione in blocchi in App per la logica di Azure

Articolo
01/04/2024

Si applica a: App per la logica di Azure (consumo)

App per la logica di Azure ha limiti massimi diversi per le dimensioni del contenuto del messaggio che attivano e azioni possono gestire nei flussi di lavoro dell'app per la logica, in base al tipo di risorsa dell'app per la logica e all'ambiente in cui viene eseguito il flusso di lavoro dell'app per la logica. Questi limiti consentono di ridurre il sovraccarico derivante dall'archiviazione e dall'elaborazione di messaggi di grandi dimensioni. Per altre informazioni sui limiti delle dimensioni dei messaggi, vedere Limiti dei messaggi in App per la logica di Azure.

Se si usano azioni HTTP predefinite o azioni specifiche del connettore gestito ed è necessario che App per la logica di Azure funzioni con messaggi superiori ai limiti predefiniti, è possibile abilitare la suddivisione in blocchi, che suddivide un messaggio di grandi dimensioni in messaggi più piccoli. In questo modo, è comunque possibile trasferire file di grandi dimensioni in condizioni specifiche. Infatti, quando si usano queste azioni HTTP predefinite o azioni specifiche del connettore gestito, la suddivisione in blocchi è l'unico modo in cui App per la logica di Azure può utilizzare messaggi di grandi dimensioni. Questo requisito significa che lo scambio di messaggi HTTP sottostante tra App per la logica di Azure e altri servizi deve usare la suddivisione in blocchi o che le connessioni create dai connettori gestiti che si desidera usare devono supportare anche la suddivisione in blocchi.

Nota

App per la logica di Azure non supporta la suddivisione in blocchi nei trigger a causa dell'aumento del sovraccarico dovuto allo scambio di più messaggi. App per la logica di Azure implementa anche la suddivisione in blocchi per le azioni HTTP usando il proprio protocollo, come descritto in questo articolo. Pertanto, anche se il sito Web o il servizio Web supporta la suddivisione in blocchi, non funzioneranno con la suddivisione in blocchi delle azioni HTTP. Per usare la suddivisione in blocchi delle azioni HTTP con il sito Web o il servizio Web, è necessario implementare lo stesso protocollo usato da App per la logica di Azure. In caso contrario, non abilitare la suddivisione in blocchi nell'azione HTTP.

Questo articolo offre una panoramica sul funzionamento della suddivisione in blocchi in App per la logica di Azure e su come configurare la suddivisione in blocchi per le azioni supportate.

Che cosa rende un messaggio "di grandi dimensioni"?

Un messaggio è "di grandi dimensioni" sulla base del servizio che lo gestisce. Il limite esatto dei messaggi di grandi dimensioni varia tra App per la logica di Azure e i connettori. Sia App per la logica di Azure che i connettori non sono in grado di elaborare direttamente messaggi di grandi dimensioni, che devono quindi essere suddivisi in blocchi. Per le dimensioni massime dei messaggi di App per la logica di Azure, vedere Limiti e configurazione per App per la logica. Per il limite di dimensioni dei messaggi di ogni connettore, vedere la documentazione di riferimento del connettore.

Gestione di messaggi in blocchi per App per la logica di Azure

App per la logica di Azure non è in grado di usare direttamente gli output di messaggi suddivisi in blocchi maggiori delle dimensioni massime del messaggio. Solo le azioni che supportano la suddivisione in blocchi possono accedere al contenuto dei messaggi in questi output. In tal caso, un'azione che gestisce messaggi di grandi dimensioni deve soddisfare entrambi questi criteri:

Supporto nativo della suddivisione in blocchi quando tale azione appartiene a un connettore.
Supporto della suddivisione in blocchi abilitato nella configurazione di esecuzione dell'azione.

In caso contrario, quando si tenta di accedere ad output di contenuti di grandi dimensioni si verificherà un errore di runtime. Per abilitare la suddivisione in blocchi, vedere Set up chunking support (Configurare il supporto della suddivisione in blocchi).

Gestione dei messaggi in blocchi per i connettori

I servizi che comunicano con App per la logica di Azure possono avere un proprio limite di dimensione dei messaggi. Tale limite è spesso inferiore rispetto al limite di App per la logica di Azure. Ad esempio, supponendo che supporti la suddivisione in blocchi, un connettore può considerare un messaggio di 30 MB come di grandi dimensioni, diversamente da App per la logica di Azure. Per rispettare il limite del connettore, App per la logica di Azure divide qualsiasi messaggio di dimensioni superiori a 30 MB in blocchi più piccoli.

Per i connettori che supportano la suddivisione in blocchi, il protocollo di suddivisione in blocchi sottostante è invisibile agli utenti finali. Tuttavia, non tutti i connettori supportano la suddivisione in blocchi; pertanto, questi connettori generano errori di runtime quando i messaggi in arrivo superano i limiti di dimensione dei connettori.

Per le azioni che supportano e sono abilitate per la suddivisione in blocchi, non è possibile usare corpi di trigger, variabili ed espressioni, ad @triggerBody()?['Content'] esempio perché l'uso di uno di questi input impedisce l'esecuzione dell'operazione di suddivisione in blocchi. Usare invece l'azione Componi. In particolare, è necessario creare un body campo usando l'azione Componi per archiviare l'output dei dati dal corpo del trigger, dalla variabile, dall'espressione e così via, ad esempio:

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

Quindi, per fare riferimento ai dati, nell'azione di suddivisione in blocchi, usare @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"
},

Configurare la suddivisione in blocchi su HTTP

In scenari HTTP generici è possibile dividere download e upload di contenuti di grandi dimensioni tramite HTTP, in modo che l'app per la logica e un endpoint possano scambiare messaggi di grandi dimensioni. I messaggi devono tuttavia essere suddivisi in blocchi nel modo previsto da App per la logica di Azure.

Se un endpoint ha abilitato la suddivisione in blocchi per download o upload, le azioni HTTP nell'app per la logica suddividono automaticamente i messaggi di grandi dimensioni. In caso contrario, è necessario configurare il supporto della suddivisione in blocchi nell'endpoint. Se non si possiede o controlla l'endpoint o il connettore, l'opzione per configurare la suddivisione in blocchi non sarà disponibile.

Se un'azione HTTP non abilita già la suddivisione in blocchi, è necessario configurare anche la suddivisione in blocchi nella proprietà runTimeConfiguration dell'azione. È possibile impostare questa proprietà all'interno dell'azione, sia direttamente nell'editor della visualizzazione codice, come descritto più avanti, sia nella finestra di progettazione di App per la logica, come descritto di seguito:

Nell'angolo superiore destro dell'azione HTTP, scegliere il pulsante con puntini di sospensione ( ... ), quindi scegliere Impostazioni.
In Trasferimento di contenuto, impostare Consenti la divisione in blocchi su On.
Per continuare a configurare la suddivisione in blocchi per download o upload, proseguire con le sezioni seguenti.

Download di contenuti in blocchi

Molti endpoint inviano automaticamente messaggi di grandi dimensioni in blocchi quando vengono scaricati tramite una richiesta HTTP GET. Per scaricare messaggi in blocchi da un endpoint tramite HTTP, l'endpoint deve supportare le richieste di contenuto parziale o i download in blocchi. Quando l'app per la logica invia una richiesta HTTP GET a un endpoint per il download di contenuti e l'endpoint risponde con un codice di stato "206", la risposta contiene contenuti in blocchi. App per la logica di Azure non è in grado di controllare se un endpoint supporta richieste parziali. Tuttavia, quando l'app per la logica ottiene la prima risposta "206", invia automaticamente più richieste per scaricare tutto il contenuto.

Per controllare se un endpoint è in grado di supportare contenuti parziali, inviare una richiesta HEAD. Tale richiesta consente di determinare se la risposta contiene l'intestazione Accept-Ranges. In questo modo, se l'endpoint supporta i download in blocchi ma non invia contenuti in blocchi, è possibile suggerire questa opzione impostando l'intestazione Range nella richiesta HTTP GET.

Questa procedura descrive il processo dettagliato che App per la logica di Azure usa per il download di contenuti in blocchi da un endpoint all'app per la logica:

L'app per la logica invia una richiesta HTTP GET all'endpoint.

L'intestazione della richiesta può includere facoltativamente un campo Range che descrive un intervallo di byte per la richiesta di blocchi di contenuti.
L'endpoint risponde con il codice di stato "206" e un corpo del messaggio HTTP.

I dettagli sul contenuto in questo blocco vengono visualizzati nell'intestazione della Content-Range risposta, incluse le informazioni che consentono ad App per la logica di determinare l'inizio e la fine del blocco, oltre alle dimensioni totali dell'intero contenuto prima della suddivisione in blocchi.
L'app per la logica invia automaticamente richieste HTTP GET di follow-up.

L'app per la logica invia richieste GET di follow-up fino a quando l'intero contenuto non viene recuperato.

Ad esempio, questa definizione di azione mostra una richiesta HTTP GET che imposta l'intestazione Range. L'intestazione suggerisce che l'endpoint deve rispondere con un contenuto suddiviso in blocchi:

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

La richiesta GET imposta l'intestazione "Range" (Intervallo) su "bytes= 0-1023", ovvero sull'intervallo di byte. Se l'endpoint supporta richieste di contenuto parziale, risponde con un blocco di contenuto nell'intervallo richiesto. In base all'endpoint, il formato esatto per il campo di intestazione "Range" può variare.

Upload di contenuti in blocchi

Per caricare contenuti in blocchi da un'azione HTTP, nell'azione deve essere abilitato il supporto della suddivisione in blocchi tramite la proprietà runtimeConfiguration. Questa impostazione consente all'azione di avviare il protocollo di suddivisione in blocchi. L'app per la logica può quindi inviare un messaggio POST o PUT iniziale all'endpoint di destinazione. Quando l'endpoint risponde con le dimensioni del blocco suggerite, l'app per la logica invia richieste HTTP PATCH di follow-up contenenti i blocchi di contenuto.

I passaggi seguenti descrivono il processo dettagliato usato da App per la logica per caricare contenuto in blocchi dall'app per la logica a un endpoint:

L'app per la logica invia una richiesta HTTP POST o PUT iniziale con corpo del messaggio vuoto. L'intestazione della richiesta include le informazioni seguenti sul contenuto che l'app per la logica vuole caricare in blocchi:

Campo intestazione della richiesta di App per la logica di Azure	valore	Tipo	Descrizione
x-ms-transfer-mode	suddiviso in blocchi	string	Indica che il contenuto viene caricato in blocchi
x-ms-content-length	<content-length>	Integer	Dimensioni dell'intero contenuto in byte prima della suddivisione in blocchi

L'endpoint risponde con il codice di stato di esito positivo "200" e le informazioni seguenti:

Campo intestazione della risposta dell'endpoint	Type	Obbligatoria	Descrizione
Posizione	string	Sì	Percorso URL a cui inviare i messaggi HTTP PATCH
x-ms-chunk-size	Integer	No	Dimensioni del blocco suggerite in byte

L'app per la logica crea e invia messaggi PATCH HTTP di completamento, ognuno con le informazioni seguenti:

Un blocco di contenuto basato su x-ms-chunk-size o su dimensioni calcolate internamente finché tutto il contenuto corrispondente a x-ms-content-length non viene caricato in sequenza

Le informazioni di intestazione seguenti sul blocco di contenuto inviato in ogni messaggio PATCH:

Campo intestazione della richiesta di App per la logica di Azure	valore	Tipo	Descrizione
Content-Range	<range>	string	Intervallo in byte del blocco di contenuto corrente, incluso il valore iniziale, il valore finale e le dimensioni totali del contenuto, ad esempio: "bytes=0-1023/10100"
Content-Type	<content-type>	string	Tipo di contenuto in blocchi
Content-Length	<content-length>	string	Lunghezza della dimensione in byte del blocco corrente

Dopo ogni richiesta PATCH, l'endpoint conferma la ricezione di ogni blocco rispondendo con il codice di stato "200" e le intestazioni di risposta seguenti:

Campo intestazione della risposta dell'endpoint	Type	Obbligatoria	Descrizione
Range	string	Sì	Intervallo di byte relativo al contenuto ricevuto dall'endpoint, ad esempio: "bytes = 0-1023"
x-ms-chunk-size	Integer	No	Dimensioni del blocco suggerite in byte

Ad esempio, questa definizione di azione mostra una richiesta HTTP POST per il caricamento di contenuti in blocchi a un endpoint. Nella proprietà dell'azione runTimeConfiguration, la proprietà contentTransfer imposta transferMode su chunked:

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