Como usar fluxos de dynamoDB

Os fluxos do DynamoDB são um recurso do serviço de banco de dados AWS DynamoDB que fornece uma sequência ordenada por tempo de alterações de dados que são feitas em uma tabela. Você pode ativar os fluxos da AWS DynamoDB em uma tabela para capturar automaticamente dados novos ou antigos. Claro, você também pode configurá -lo para capturar os dois.

Notavelmente, os fluxos podem desencadear os pipelines de dados em tempo real, permitindo que os aplicativos reagem a alterações nos dados em segundos. Além disso, os fluxos podem ajudar a criar os aplicativos que respondem a alterações nos dados, acionando as ações correspondentes, como atualizar outros dados na tabela ou acionar os serviços externos.

Os dados estão disponíveis no fluxo por 24 horas por padrão. No entanto, você pode personalizar o período de retenção de dados para atender às suas necessidades.

Casos de uso comuns para fluxos de dynamoDB

Alguns dos casos de uso diário para fluxos do DynamoDB incluem o seguinte:

• Um caso de uso para fluxos do DynamoDB é ativar o processamento e análise de dados em tempo real. Quando você habilita os fluxos de dynamoDB em uma tabela de dynamoDB, quaisquer alterações nos dados da tabela são capturadas e enviadas para um fluxo especificado em tempo real. Esse recurso permite o processamento e a análise imediatos dos dados, permitindo que as empresas respondam rapidamente às mudanças e tomem decisões orientadas por dados.
• Os fluxos do DynamoDB também podem criar um histórico de alterações nos dados de uma tabela. Notavelmente, armazenar os registros do fluxo em um armazenamento de dados separado permite que as empresas mantenham um registro completo de todas as alterações feitas na tabela ao longo do tempo. Isso é útil para fins de auditoria e conformidade. Além disso, você pode usar os dados armazenados para depuração e solução de problemas quando ocorre um problema.
• Além disso, os fluxos do DynamoDB podem ajudar a acionar as funções Lambda em resposta a mudanças nos dados da tabela. Esse recurso permite o processamento de dados automático e em tempo real, permitindo que as empresas automatizem tarefas e processos que exigem informações atualizadas da tabela. Por exemplo, você pode desencadear uma função Lambda para enviar uma notificação a um cliente quando o status do pedido mudar ou atualizar um índice de pesquisa quando um produto é adicionado à tabela.

Guia passo a passo sobre como ativar e usar fluxos de dynamoDB

Existem vários métodos para ativar os fluxos de dynamoDB em suas mesas. Os métodos mais comuns incluem o seguinte:

Ativar fluxos do DynamoDB usando a chamada da API CreateTable

Notavelmente, você pode ativar os fluxos do DynamoDB usando a chamada da API CreateTable usando o seguinte comando:

AWS DynamoDB Create-Table \
--Nome da tabela \
--Definições de atributo \
--Schema-chave \
--provisionado-throughput \
--Specificação de fluxo com streamilabled = true, streamViewType =

Ativar fluxos do DynamoDB com a chamada API Updatetable

A sintaxe a seguir ilustra como você pode ativar os fluxos usando a chamada API UPLAPTETABLE:

AWS DynamoDB Update-Table \
--Nome da tabela \
--Specificação de fluxo com streamilabled = true, streamViewType =

Depois de habilitar seu fluxo com sucesso, prossiga a chamada da API DeclateStream para recuperar o ARN do fluxo e outros detalhes:

AWS DynamoDB descreve-se-stream \
--Nome da tabela

Você também pode usar a chamada da API GetSharditerator para obter um iterador Shard. Um iterador de shard lê os dados do seu fluxo. A sintaxe é a seguinte:

AWS DynamoDB Get-Shard-Titerator \
--Nome da tabela \
--shard-id \
--SHARD-TIERATOR-TYPE

Por fim, use o iterador Shard ao lado da chamada da API GetRecords para ler todos os registros do seu fluxo. A sintaxe a seguir ajudará:

AWS DynamoDB Get-Records \
--shard-piadeator

Notavelmente, a sintaxe anterior é para a AWS CLI, mas comandos semelhantes estão disponíveis para os SDKs da AWS em diferentes linguagens de programação.

Usando fluxos do DynamoDB com a função Lambda

Depois de ativar os fluxos do DynamoDB em seu banco de dados, você pode configurá -lo para usar a função Lambda. As etapas a seguir devem ajudar:

Passo 1: Comece criando uma função lambda que os registros do fluxo que são capturados por fluxos do DynamoDB desencadearão. Sua função Lambda deve conter o código para processar os registros do fluxo e executar quaisquer ações que você possa solicitar.

Passo 2: Crie uma função de IAM que concede a função Lambda as permissões apropriadas para acessar os registros do fluxo. Anexe este papel IAM à função Lambda.

Etapa 3: Configure o fluxo do DynamoDB para acionar a função Lambda sempre que novos registros de fluxo estão disponíveis.

Depois que essas etapas forem concluídas, os fluxos do DynamoDB começarão a capturar os eventos de modificação de dados para a tabela DynamoDB especificada e acionará a função Lambda para processar os registros do fluxo. A função Lambda pode então executar qualquer ação que você definir em seu código.

Conclusão

Os fluxos do DynamoDB se destacam como um serviço totalmente gerenciado com excelentes benefícios. Permite capturar e processar os eventos de modificação de dados em tempo real. Obviamente, você pode usar os dados para criar os aplicativos que reagem a mudanças nos dados à medida que ocorrem, em vez de ter que pesquisar mudanças periodicamente.