As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.
Na primeira etapa do Tutorial: Processar dados de ações em tempo real usando a KPL e a KCL 1.x, crie o fluxo que será usado em etapas subsequentes.
Para criar um fluxo
Faça login no AWS Management Console e abra o console do Kinesis em https://console.aws.amazon.com/kinesis
. -
Selecione Fluxos de dados no painel de navegação.
-
Na barra de navegação, expanda o seletor de região e escolha uma região.
-
Selecione Criar fluxo do Kinesis.
-
Insira um nome para seu fluxo (por exemplo,
StockTradeStream
). -
Digite
1
como o número de fragmentos, mas deixe Estimar o número de fragmentos necessários recolhido. -
Selecione Criar fluxo do Kinesis.
Na página de lista Fluxos do Kinesis, o status do fluxo é CREATING
enquanto ele está sendo criado. Quando o fluxo fica pronto para uso, o status é alterado para ACTIVE
. Escolha o nome do fluxo. Na página exibida, a guia Detalhes exibe um resumo da configuração do fluxo. A seção Monitoramento exibe informações de monitoramento do fluxo.
Informações adicionais sobre fragmentos
Ao começar a usar o Kinesis Data Streams fora deste tutorial, pode ser necessário planejar o processo de criação de fluxos mais cuidadosamente. É necessário planejar para a demanda máxima esperada ao provisionar fragmentos. Usando este cenário como exemplo, o tráfego de negociações da bolsa de valores dos EUA atinge o pico durante o dia (fuso horário do leste dos EUA) e, a partir desse horário, é preciso tirar amostras das estimativas de demanda. Em seguida, pode-se opcionalmente provisionar para a máxima demanda esperada ou expandir e reduzir o fluxo em resposta às variações de demanda.
Um fragmento é uma unidade de capacidade de throughput. Na página Criar fluxo do Kinesis, expanda Estime o número de fragmentos necessários. Digite o tamanho médio do registro, o máximo de registros gravados por segundo e o número de aplicativos de consumo usando as seguintes diretrizes:
- Tamanho médio do registro
-
Uma estimativa do tamanho médio calculado dos registros. Se esse valor não for conhecido, use o tamanho de registro máximo estimado.
- Máximo de registros gravados
-
Considere o número de entidades que fornecem dados e o número aproximado de registros por segundo produzidos por cada um. Por exemplo, ao receber dados de negociações de ações provenientes de 20 servidores mercantis, com cada um gerando 250 negociações por segundo, o número total de transações (registros) por segundo é 5.000 por segundo.
- Número de aplicativos de consumo
-
Número de aplicativos que fazem leitura do fluxo de forma independente para processar o fluxo de outro modo e produzir saída diferente. Cada aplicativo pode ter várias instâncias em execução em máquinas diferentes (ou seja, execução em um cluster) para dar conta de um fluxo de alto volume.
Se o número estimado de fragmentos mostrado exceder o limite atual de fragmentos, poderá ser necessário enviar uma solicitação para aumentar esse limite para poder criar um fluxo com esse número de fragmentos. Para solicitar um aumento do limite de fragmentos, use o formulário de limites do Kinesis Data Streams
Próximas etapas
Criar um usuário e uma política do IAM