Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
Filtrare gli eventi da una fonte di eventi Amazon MQ
Puoi utilizzare il filtraggio degli eventi per controllare quali record di un flusso o di una coda Lambda invia alla funzione. Per informazioni generali su come funziona il filtraggio degli eventi, consulta. Controlla quali eventi Lambda invia alla tua funzione
Questa sezione si concentra sul filtraggio degli eventi per le sorgenti di eventi Amazon MQ.
Nozioni di base sul filtraggio degli eventi di Amazon MQ
Supponiamo che la coda di messaggi di Amazon MQ contenga messaggi in JSON formato valido o come stringhe semplici. Un record di esempio sarebbe simile al seguente, con i dati convertiti in una stringa codificata Base64 nel campo data
.
Per i broker sia Active MQ sia Rabbit MQ, puoi utilizzare il filtraggio degli eventi per filtrare i record utilizzando la chiave data
. Supponiamo che la coda di Amazon MQ contenga messaggi nel seguente JSON formato.
{ "timeout": 0, "IPAddress": "203.0.113.254" }
Per filtrare solo i record in cui il campo timeout
è maggiore di 0, l'oggetto FilterCriteria
sarebbe il seguente.
{ "Filters": [ { "Pattern": "{ \"data\" : { \"timeout\" : [ { \"numeric\": [ \">\", 0] } } ] } }" } ] }
Per maggiore chiarezza, ecco il valore del filtro Pattern
espanso in chiaro. JSON
{ "data": { "timeout": [ { "numeric": [ ">", 0 ] } ] } }
Puoi aggiungere il filtro utilizzando la console AWS CLI o un AWS SAM modello.
Con Amazon MQ, puoi anche filtrare i record in cui il messaggio è una stringa semplice. Supponiamo di voler elaborare solo i record in cui il messaggio inizia con "Risultato: ". L'oggetto FilterCriteria
dovrebbe avere la struttura seguente.
{ "Filters": [ { "Pattern": "{ \"data\" : [ { \"prefix\": \"Result: \" } ] }" } ] }
Per maggiore chiarezza, ecco il valore del filtro Pattern
espanso in chiaro. JSON
{ "data": [ { "prefix": "Result: " } ] }
Puoi aggiungere il filtro utilizzando la console AWS CLI o un AWS SAM modello.
I messaggi Amazon MQ devono essere costituiti da UTF -8 stringhe codificate, semplici o in formato. JSON Questo perché Lambda decodifica gli array di byte Amazon MQ in UTF -8 prima di applicare i criteri di filtro. Se i tuoi messaggi utilizzano un'altra codifica, ad esempio UTF -16 oASCII, o se il formato del messaggio non corrisponde al FilterCriteria
formato, Lambda elabora solo i filtri dei metadati. La tabella seguente riepiloga il comportamento specifico:
Formato messaggio in arrivo | Formato del modello di filtro per le proprietà di messaggi | Operazione risultante |
---|---|---|
Stringa normale |
Stringa normale |
Filtri Lambda in base ai criteri di filtro. |
Stringa normale |
Nessun modello di filtro per le proprietà dei dati |
Filtri Lambda (solo sulle altre proprietà dei metadati) in base ai criteri di filtro. |
Stringa normale |
Valido JSON |
Filtri Lambda (solo sulle altre proprietà dei metadati) in base ai criteri di filtro. |
Valido JSON |
Stringa normale |
Filtri Lambda (solo sulle altre proprietà dei metadati) in base ai criteri di filtro. |
Valido JSON |
Nessun modello di filtro per le proprietà dei dati |
Filtri Lambda (solo sulle altre proprietà dei metadati) in base ai criteri di filtro. |
Valido JSON |
Valido JSON |
Filtri Lambda in base ai criteri di filtro. |
Stringa codificata non UTF -8 |
JSON, stringa semplice o nessun modello |
Filtri Lambda (solo sulle altre proprietà dei metadati) in base ai criteri di filtro. |