

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

# Criar um fluxo de dados
<a name="tutorial-stock-data-kplkcl-create-stream"></a>

Na primeira etapa do [Tutorial: Processar dados de ações em tempo real usando a KPL e a KCL 1.x[Tutorial: Processar dados de ações em tempo real usando a KPL e a KCL 1.x](tutorial-stock-data-kplkcl.md)](tutorial-stock-data-kplkcl.md), crie o fluxo que será usado em etapas subsequentes.

**Para criar um fluxo**

1. [Faça login no Console de gerenciamento da AWS e abra o console do Kinesis em https://console.aws.amazon.com /kinesis.](https://console.aws.amazon.com/kinesis)

1. Selecione **Fluxos de dados** no painel de navegação.

1. Na barra de navegação, expanda o seletor de região e escolha uma região.

1. Selecione **Criar fluxo do Kinesis**.

1. Insira um nome para seu fluxo (por exemplo, **StockTradeStream**).

1. Digite **1** como o número de fragmentos, mas deixe **Estimar o número de fragmentos necessários** recolhido.

1. 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
<a name="tutorial-stock-data-kplkcl-create-stream-info"></a>

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](https://console.aws.amazon.com/support/home#/case/create?issueType=service-limit-increase&limitType=service-code-kinesis). Para obter mais informações sobre fluxos e fragmentos, consulte [Criar e gerenciar fluxos de dados do Kinesis](working-with-streams.md).

## Próximas etapas
<a name="tutorial-stock-data-kplkcl-create-stream-next"></a>

[Criar um usuário e uma política do IAM](tutorial-stock-data-kplkcl-iam.md)