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 SNS argomenti, 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'utilizzo 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.

Questa pagina mostra come distribuire la Event Storage and Backup Pipeline e iscriverla a un argomento di AmazonSNS. Questo processo trasforma automaticamente il AWS SAM modello associato alla pipeline in uno AWS 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:

  • SQSCoda Amazon

  • Funzione Lambda

  • Flussi di distribuzione Firehose

  • S3 backup bucket Amazon S3

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

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

Per ulteriori informazioni su come filtrare gli eventi, consulta Politiche di filtro degli SNS abbonamenti Amazon 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. Scegli Sfoglia l'archivio di app serverless, Applicazioni pubbliche, Mostra app che creano ruoli o politiche di risorse personalizzati. IAM

    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 AWS CloudFormation stack precedentemente distribuito (anziché crearne uno nuovo).

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

    3. (Facoltativo) Per DataTransformationFunctionArn, inserisci la ARN 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 TopicArn, inserisci ARN l'SNSargomento Amazon 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 entrata. 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 S3. In assenza di valori immessi, non viene utilizzato alcun prefisso.

    9. (Facoltativo) Per SubscriptionFilterPolicy, inserisci la politica di filtro degli SNS abbonamenti Amazon, nel JSON formato, 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. Scegli Riconosco che questa app crea IAM ruoli personalizzati, politiche delle risorse e distribuisce applicazioni annidate. quindi scegli Deploy.

Nello stato di distribuzione per my-apppagina, Lambda visualizza lo stato L'applicazione è in fase di distribuzione.

Nella sezione Risorse, AWS CloudFormation inizia a creare lo stack e visualizza lo stato CREATE_IN_ PROGRESS per ogni risorsa. Quando il processo è completo, AWS CloudFormation visualizza lo stato _. CREATE COMPLETE

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

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