Creazione e gestione di stream in QLDB - Database Amazon Quantum Ledger (Amazon) QLDB
Parametri dello streamStream ARNAWS Management ConsoleStati dello streamGestione degli stream compromessi

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

Creazione e gestione di stream in QLDB

Importante

Avviso di fine del supporto: i clienti esistenti potranno utilizzare Amazon QLDB fino alla fine del supporto il 31/07/2025. Per ulteriori dettagli, consulta Migrare un Amazon QLDB Ledger ad Amazon Aurora Postgre. SQL

Amazon QLDB fornisce API operazioni per creare e gestire un flusso di dati del journal dal registro ad Amazon Kinesis Data Streams. Lo QLDB stream acquisisce ogni revisione del documento inserita nel diario e la invia a un flusso di dati Kinesis.

Puoi usare the AWS Management Console AWS SDK, an o the AWS Command Line Interface (AWS CLI) per creare un flusso di diario. Inoltre, puoi anche utilizzare un AWS CloudFormationmodello per creare stream. Per ulteriori informazioni, consulta la risorsa AWS::QLDB: :Stream nella Guida per l'AWS CloudFormation utente.

Parametri dello stream

Per creare uno stream di QLDB journal, è necessario fornire i seguenti parametri di configurazione:

Nome del libro mastro

Il QLDB libro mastro di cui desideri trasmettere i dati del diario a Kinesis Data Streams.

Nome del flusso

Il nome che vuoi assegnare al flusso del diario. QLDB I nomi definiti dall'utente possono aiutare a identificare e indicare lo scopo di un flusso.

Il nome del flusso deve essere univoco tra gli altri flussi attivi per un determinato libro mastro. I nomi degli stream hanno gli stessi vincoli di denominazione dei nomi dei libri contabili, come definito in. Quote e limiti in Amazon QLDB

Oltre al nome dello stream, QLDB assegna un ID di stream a ogni QLDB stream che crei. L'ID dello stream è unico tra tutti gli stream di un determinato registro, indipendentemente dal loro stato.

Data e ora di inizio

La data e l'ora da cui iniziare lo streaming dei dati del diario. Questo valore può corrispondere a qualsiasi data e ora del passato, ma non a quelle future.

Data e ora di fine

(Facoltativo) La data e l'ora che specificano il termine dello streaming.

Se crei uno stream indefinito senza ora di fine, devi annullarlo manualmente per terminare lo streaming. Puoi anche annullare uno stream attivo e finito che non ha ancora raggiunto la data e l'ora di fine specificate.

Flusso di dati Kinesis di destinazione

La risorsa di destinazione Kinesis Data Streams su cui lo stream scrive i record di dati. Per informazioni su come creare un flusso di dati Kinesis, consulta Creazione e aggiornamento di flussi di dati nella Amazon Kinesis Data Streams Developer Guide.

Importante

  • I flussi tra regioni e tra account non sono supportati. Il flusso di dati Kinesis specificato deve trovarsi nello stesso Regione AWS account del registro.

  • L'aggregazione dei record in Kinesis Data Streams è abilitata per impostazione predefinita. Questa opzione consente di QLDB pubblicare più record di dati in un singolo record Kinesis Data Streams, aumentando il numero di record API inviati per chiamata.

    L'aggregazione dei record ha importanti implicazioni per l'elaborazione dei record e richiede la disaggregazione nello stream consumer. Per ulteriori informazioni, consulta i concetti KPL chiave e la deaggregazione dei consumatori nella Amazon Kinesis Data Streams Developer Guide.

IAMruolo

Il IAM ruolo che consente di QLDB assumere le autorizzazioni di scrittura per il flusso di dati Kinesis. Puoi usare la QLDB console per creare automaticamente questo ruolo oppure puoi crearlo manualmente. IAM Per informazioni su come crearlo manualmente, consultaAutorizzazioni di streaming.

Per passare un ruolo a QLDB quando si richiede uno stream di journal, è necessario disporre delle autorizzazioni per eseguire l'iam:PassRoleazione sulla risorsa del IAM ruolo.

Stream ARN

Ogni stream di QLDB journal è una sottorisorsa di un libro mastro ed è identificato in modo univoco da un Amazon Resource Name (). ARN Di seguito è riportato un esempio ARN di QLDB stream con un ID stream pari a IiPT4brpZCqCq3f4MTHbYy per un registro denominato. exampleLedger

arn:aws:qldb:us-east-1:123456789012:stream/exampleLedger/IiPT4brpZCqCq3f4MTHbYy

La sezione seguente descrive come creare e annullare uno QLDB stream utilizzando. AWS Management Console

AWS Management Console

Segui questi passaggi per creare o annullare uno QLDB streaming utilizzando la QLDB console.

Per creare uno stream (console)

  1. Accedi a e apri AWS Management Console la QLDB console Amazon all'indirizzo https://console.aws.amazon.com/qldb.

  2. Nel pannello di navigazione, seleziona Streams (Flussi).

  3. Selezionare Create QLDB stream (Crea flusso &AK;).

  4. Nella pagina Crea QLDB stream, inserisci le seguenti impostazioni:

    • Nome dello stream: il nome che vuoi assegnare allo QLDB stream.

    • Registro: il libro mastro di cui desideri trasmettere in streaming i dati del diario.

    • Data e ora di inizio: il timestamp inclusivo in Coordinated Universal Time (UTC) da cui iniziare lo streaming dei dati del diario. Il valore predefinito di questo timestamp è la data e l'ora correnti. Non può essere nel futuro e deve essere precedente alla data e all'ora di fine.

    • Data e ora di fine: (Facoltativo) Il timestamp esclusivo (UTC) che specifica quando termina lo streaming. Se mantieni vuoto questo parametro, lo stream viene eseguito a tempo indeterminato fino a quando non lo annulli.

    • Flusso di destinazione: la risorsa di destinazione Kinesis Data Streams su cui lo stream scrive i record di dati. Utilizza il seguente ARN formato.

      arn:aws:kinesis:aws-region:account-id:stream/kinesis-stream-name

      Di seguito è riportato un esempio.

      arn:aws:kinesis:us-east-1:123456789012:stream/stream-for-qldb

      Gli stream tra regioni e tra account non sono supportati. Il flusso di dati Kinesis specificato deve trovarsi nello stesso Regione AWS account del registro.

    • Abilita l'aggregazione dei record in Kinesis Data Streams — (Attivata per impostazione predefinita) QLDB Consente di pubblicare più record di dati in un singolo record Kinesis Data Streams, aumentando il numero di record inviati per chiamata. API

    • Accesso al servizio: il IAM ruolo che concede le autorizzazioni di QLDB scrittura al flusso di dati Kinesis.

      Per passare un ruolo a QLDB quando si richiede un flusso di journal, è necessario disporre delle autorizzazioni per eseguire l'iam:PassRoleazione sulla risorsa del ruolo. IAM

      • Crea e usa un nuovo ruolo di servizio: consenti alla console di creare un nuovo ruolo per te con le autorizzazioni richieste per il flusso di dati Kinesis specificato.

      • Usa un ruolo di servizio esistente: per scoprire come creare manualmente questo ruolo inIAM, consulta. Autorizzazioni di streaming

    • Tag: (Facoltativo) Aggiungi metadati allo stream allegando i tag come coppie chiave-valore. Puoi aggiungere tag allo stream per organizzarli e identificarli. Per ulteriori informazioni, consulta Etichettare le risorse Amazon QLDB.

      Scegli Aggiungi tag, quindi inserisci le coppie chiave-valore appropriate.

  5. Quando le impostazioni sono quelle che desideri, scegli Crea QLDB stream.

    Se l'invio della richiesta va a buon fine, la console torna alla pagina principale Streams ed elenca i tuoi QLDB stream con il loro stato attuale.

  6. Dopo che lo streaming è attivo, usa Kinesis per elaborare i dati di streaming con un'applicazione consumer.

    Apri la console Kinesis Data https://console.aws.amazon.com/kinesis/Streams all'indirizzo.

Per informazioni sul formato dei record di dati di flusso, consulta. QLDBstreaming di record in Kinesis

Per informazioni su come gestire gli stream che generano un errore, consultaGestione degli stream compromessi.

Per annullare uno stream (console)

Non puoi riavviare uno QLDB stream dopo averlo annullato. Per riprendere la consegna dei dati a Kinesis Data Streams, puoi creare un nuovo stream. QLDB

  1. Apri la QLDB console Amazon all'indirizzo https://console.aws.amazon.com/qldb.

  2. Nel pannello di navigazione, seleziona Streams (Flussi).

  3. Nell'elenco degli QLDB stream, seleziona lo stream attivo che desideri annullare.

  4. Scegli Annulla streaming. Confermalo inserendo cancel stream nell'apposita casella.

Per informazioni sull'utilizzo di QLDB API with an AWS SDK o the AWS CLI per creare e gestire i flussi del diario, consultaSviluppo con stream in QLDB.

Stati dello stream

Lo stato di uno QLDB stream può essere uno dei seguenti:

  • ACTIVE— È attualmente in streaming o è in attesa di trasmettere i dati (per uno streaming indefinito senza ora di fine).

  • COMPLETED— Ha terminato con successo lo streaming di tutti i blocchi del journal entro l'intervallo di tempo specificato. Si tratta di uno stato terminale.

  • CANCELED— È stato interrotto da una richiesta dell'utente prima dell'ora di fine specificata e non trasmette più attivamente i dati in streaming. Si tratta di uno stato terminale.

  • IMPAIRED— Non è in grado di scrivere record su Kinesis a causa di un errore che richiede l'intervento dell'utente. Si tratta di uno stato non terminale ripristinabile.

    Se risolvi l'errore entro un'ora, lo stream passa automaticamente allo stato. ACTIVE Se l'errore rimane irrisolto dopo un'ora, lo stream passa automaticamente allo FAILED stato.

  • FAILED— Non è in grado di scrivere record su Kinesis a causa di un errore e si trova in uno stato terminale irrecuperabile.

Il diagramma seguente illustra come una risorsa di QLDB flusso può passare da uno stato all'altro.

Diagramma di stato che mostra come una risorsa di QLDB flusso può passare dallo stato attivo, annullato, completato, danneggiato e non riuscito.

Scadenza per i flussi terminali

Le risorse di streaming che si trovano in uno stato terminale (CANCELEDCOMPLETED, eFAILED) sono soggette a un periodo di conservazione di 7 giorni. Vengono eliminate automaticamente dopo la scadenza di questo limite.

Dopo l'eliminazione di uno stream terminale, non è più possibile utilizzare la QLDB console o il QLDB API per descrivere o elencare la risorsa di streaming.

Gestione degli stream compromessi

Se il tuo stream riscontra un errore, passa prima allo stato. IMPAIRED QLDBcontinua a riprovare lo IMPAIRED streaming per un massimo di un'ora.

Se risolvi l'errore entro un'ora, lo stream passa automaticamente allo ACTIVE stato. Se l'errore rimane irrisolto dopo un'ora, lo stream passa automaticamente allo FAILED stato.

Uno stream danneggiato o non riuscito può avere una delle seguenti cause di errore:

  • KINESIS_STREAM_NOT_FOUND— La risorsa Kinesis Data Streams di destinazione non esiste. Verifica che il flusso di dati Kinesis fornito nella richiesta di QLDB streaming sia corretto. Quindi, vai su Kinesis e crea il flusso di dati che hai specificato.

  • IAM_PERMISSION_REVOKED— QLDB non dispone di autorizzazioni sufficienti per scrivere record di dati nel flusso di dati Kinesis specificato. Verifica di aver definito una policy per il flusso di dati Kinesis specificato che conceda al QLDB service (qldb.amazonaws.com) le autorizzazioni per le seguenti azioni:

    • kinesis:PutRecord

    • kinesis:PutRecords

    • kinesis:DescribeStream

    • kinesis:ListShards

Monitoraggio dei flussi compromessi

Se uno streaming viene interrotto, la QLDB console visualizza un banner che mostra i dettagli sullo streaming e l'errore riscontrato. Puoi anche utilizzare l'DescribeJournalKinesisStreamAPIoperazione per ottenere lo stato di uno stream e la causa dell'errore sottostante.

Inoltre, puoi utilizzare Amazon CloudWatch per creare un allarme che monitora la IsImpaired metrica di uno stream. Per informazioni sul monitoraggio delle QLDB metriche con CloudWatch, consulta. QLDBDimensioni e metriche di Amazon