View a markdown version of this page

Implementazione e sottoscrizione della Event Storage and Backup Pipeline su Amazon SNS - Amazon Simple Notification Service

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à.

Implementazione e sottoscrizione della Event Storage and Backup Pipeline su Amazon SNS

Per l'archiviazione e l'analisi degli eventi, Amazon SNS ora consiglia di utilizzare la sua integrazione nativa con Amazon Data Firehose. Puoi abbonare i flussi di distribuzione Firehose agli argomenti SNS, il che ti consente di inviare notifiche a endpoint di archiviazione e analisi come i bucket Amazon Simple Storage Service (Amazon S3), le tabelle Amazon Redshift, Amazon Service (Service) e altro ancora. OpenSearch OpenSearch L'uso di Amazon SNS con i flussi di distribuzione Firehose è una soluzione completamente gestita e priva di codice che non richiede l'utilizzo di funzioni. AWS Lambda Per ulteriori informazioni, consulta Flussi di distribuzione da Fanout a Firehose.

Questo tutorial mostra come distribuire la pipeline di storage di eventi e di backup e iscriverla a un argomento Amazon SNS. Questo processo trasforma automaticamente il AWS SAM modello associato alla pipeline in uno CloudFormation stack, quindi distribuisce lo stack nel tuo. Account AWS Il processo inoltre crea e configura il set di risorse che compongono la pipeline di storage di eventi e di backup, tra cui:

  • Coda Amazon SQS

  • funzione Lambda

  • Flussi di distribuzione Firehose

  • S3 backup bucket Amazon S3

Per ulteriori informazioni sulla configurazione di uno stream con un bucket Amazon S3 come destinazione, consulta Amazon Data S3DestinationConfiguration Firehose API Reference.

Per ulteriori informazioni sulla trasformazione degli eventi e sulla configurazione del buffering degli eventi, della compressione degli eventi e della crittografia degli eventi, consulta Creating an Delivery Stream nella Amazon Data Firehose Developer Guide.

Per ulteriori informazioni su come filtrare gli eventi, consulta Policy di filtro degli abbonamenti Amazon SNS in questa guida.

  1. Accedi alla console AWS Lambda.

  2. Nel riquadro di navigazione, selezionare Functions (Funzioni) e quindi Create function (Crea funzione).

  3. Nella pagina Create function (Crea funzione), procedere come segue:

    1. Scegliere Browse serverless app repository (Sfoglia repository app serverless), Public applications (Applicazioni pubbliche), Show apps that create custom IAM roles or resource policies (Mostra applicazioni in grado di creare ruoli IAM o policy di risorse personalizzati).

    2. Cercare fork-event-storage-backup-pipeline e scegliere l'applicazione.

  4. Nella pagina fork-event-storage-backup-pipeline, procedi come segue:

    1. Nella sezione Application settings (Impostazioni applicazione), immettere un Application name (Nome applicazione) (ad esempio my-app-backup).

      Nota

      • Il nome dell'applicazione deve essere univoco per ogni distribuzione. Se riutilizzi il nome di un'applicazione, la distribuzione aggiornerà solo lo CloudFormation stack precedentemente distribuito (anziché crearne uno nuovo).

    2. (Facoltativo) Per BucketArn, inserisci l'ARN del bucket Amazon S3 in cui vengono caricati gli eventi in entrata. Se non inserisci un valore, nel tuo account viene creato un nuovo bucket Amazon S3. AWS

    3. (Facoltativo) Per DataTransformationFunctionArn, inserisci l'ARN della funzione Lambda attraverso la quale vengono trasformati gli eventi in entrata. In assenza di valori immessi, la trasformazione dei dati è disabilitata.

    4. (Facoltativo) Immettete una delle seguenti LogLevelimpostazioni per l'esecuzione della funzione Lambda dell'applicazione:

      • DEBUG

      • ERROR

      • INFO (predefinito)

      • WARNING

    5. Per esempio TopicArn, inserisci l'ARN dell'argomento Amazon SNS a cui deve essere sottoscritta questa istanza della pipeline fork.

    6. (Facoltativo) Per StreamBufferingIntervalInSecondse StreamBufferingSizeInMBs, inserisci i valori per configurare il buffering degli eventi in arrivo. In assenza di valori immessi, vengono impostati 300 secondi e 5 MB.

    7. (Facoltativo) Immettete una delle seguenti StreamCompressionFormatimpostazioni per la compressione degli eventi in arrivo:

      • GZIP

      • SNAPPY

      • UNCOMPRESSED (predefinito)

      • ZIP

    8. (Facoltativo) Per StreamPrefix, inserisci il prefisso di stringa per denominare i file archiviati nel bucket di backup Amazon S3. In assenza di valori immessi, non viene utilizzato alcun prefisso.

    9. (Facoltativo) Per SubscriptionFilterPolicy, inserisci la politica di filtro degli abbonamenti Amazon SNS, in formato JSON, da utilizzare per filtrare gli eventi in arrivo. La politica di filtro decide quali eventi sono indicizzati nell'indice del servizio. OpenSearch In assenza di valori immessi, non viene applicato alcun filtro (tutti gli eventi vengono indicizzati).

    10. (Facoltativo) Per SubscriptionFilterPolicyScope, inserisci la stringa MessageBody o per MessageAttributes abilitare il filtraggio dei messaggi basato sul payload o sugli attributi.

    11. Scegliere I acknowledge that this app creates custom IAM roles, resource policies and deploys nested applications. (Riconosco che questa app crea ruoli IAM e policy di risorse personalizzati e distribuisce applicazioni nidificate.), quindi selezionare Deploy (Distribuisci).

Nella my-app pagina Stato di distribuzione per, Lambda visualizza lo stato L'applicazione è in fase di distribuzione.

Nella sezione Risorse, CloudFormation inizia a creare lo stack e visualizza lo stato CREATE_IN_PROGRESS per ogni risorsa. Quando il processo è completo, visualizza lo stato CREATE_COMPLETE. CloudFormation

Al termine della distribuzione, Lambda mostra lo stato Your application has been deployed (L'applicazione è stata distribuita).

I messaggi pubblicati sul tuo argomento Amazon SNS vengono archiviati automaticamente nel bucket di backup Amazon S3 fornito automaticamente dalla pipeline Event Storage and Backup.