Trasformazione dei record e conversione del formato - Amazon Data Firehose

Amazon Data Firehose era precedentemente noto come Amazon Kinesis Data Firehose

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

Trasformazione dei record e conversione del formato

Configura Amazon Data Firehose per trasformare e convertire i dati dei tuoi record.

  • Se scegli Amazon MSK come fonte per il tuo flusso di distribuzione:

    1. Nella sezione Trasforma i record di origine con AWS Lambda, fornisci i valori per il campo seguente:

      Trasformazione dei dati

      Per creare uno stream Firehose che non trasformi i dati in entrata, non selezionare la casella di controllo Abilita la trasformazione dei dati.

      Per specificare una funzione Lambda da richiamare e utilizzare da Firehose per trasformare i dati in entrata prima di consegnarli, seleziona la casella di controllo Abilita la trasformazione dei dati. Puoi configurare una nuova funzione Lambda utilizzando uno degli schemi Lambda o scegliere una funziona Lambda esistente. La funzione Lambda deve contenere il modello di stato richiesto da Firehose. Per ulteriori informazioni, consulta Trasformazione dei dati di Amazon Data Firehose.

    2. Nella sezione Convert record format (Converti formato record) fornire i valori per il seguente campo:

      Record format conversion (Conversione del formato record)

      Per creare uno stream Firehose che non converta il formato dei record di dati in entrata, scegliete Disabilitato.

      Per convertire il formato dei record in entrata, scegli Enabled (Abilitato), quindi specifica il formato di output desiderato. È necessario specificare una AWS Glue tabella che contenga lo schema che si desidera che Firehose utilizzi per convertire il formato di record. Per ulteriori informazioni, consulta Conversione del formato di registrazione di input in Firehose.

      Per un esempio di come impostare la conversione del formato di record conAWS CloudFormation, vedi AWS:::KinesisFirehose: DeliveryStream.

  • Se scegli Managed Service for Apache Flink o Direct PUT come origine per il tuo flusso di distribuzione, nella sezione Impostazioni sorgente:

    1. In Trasforma record, scegli una delle seguenti opzioni:

      1. Se la tua destinazione è Amazon S3 o Splunk, nella sezione Decomprimi i record di origine di CloudWatch Amazon Logs, scegli Attiva la decompressione.

      2. Nella sezione Trasforma i record di origine con AWS Lambda, fornisci i valori per il campo seguente:

        Trasformazione dei dati

        Per creare uno stream Firehose che non trasformi i dati in entrata, non selezionare la casella di controllo Abilita la trasformazione dei dati.

        Per specificare una funzione Lambda che Amazon Data Firehose possa richiamare e utilizzare per trasformare i dati in entrata prima di consegnarli, seleziona la casella di controllo Abilita la trasformazione dei dati. Puoi configurare una nuova funzione Lambda utilizzando uno degli schemi Lambda o scegliere una funziona Lambda esistente. La tua funzione Lambda deve contenere il modello di stato richiesto da Amazon Data Firehose. Per ulteriori informazioni, consulta Trasformazione dei dati di Amazon Data Firehose.

    2. Nella sezione Convert record format (Converti formato record) fornire i valori per il seguente campo:

      Record format conversion (Conversione del formato record)

      Per creare uno stream Firehose che non converta il formato dei record di dati in entrata, scegliete Disabilitato.

      Per convertire il formato dei record in entrata, scegli Enabled (Abilitato), quindi specifica il formato di output desiderato. È necessario specificare una AWS Glue tabella che contenga lo schema che desideri che Amazon Data Firehose utilizzi per convertire il formato di record. Per ulteriori informazioni, consulta Conversione del formato di registrazione di input in Firehose.

      Per un esempio di come impostare la conversione del formato di record conAWS CloudFormation, consulta AWS:::KinesisFirehose: DeliveryStream.