Etapa 3.2: Configurar a entrada

Para adicionar uma origem de streaming ao seu aplicativo

1. Na página de hub do aplicativo no console, selecione Connect streaming data (Conectar dados de streaming).

   

2. Na página exibida, analise o seguinte:

   • A seção Source, na qual você especifica uma origem de streaming para o aplicativo. É possível selecionar uma origem de streaming existente ou criar uma nova. Neste exercício, você cria um novo fluxo, o fluxo de demonstração.

      

     Por padrão, o console nomeia o fluxo de entrada de aplicativo criado como INPUT_SQL_STREAM_001. Neste exercício, mantenha esse nome como ele aparece.

      

     • Nome de referência do stream: esta opção mostra o nome do stream de entrada no aplicativo criado, SOURCE_SQL_STREAM_001. Você pode alterar o nome, mas, neste exercício, mantenha esse nome.

        

       Na configuração de entrada, mapeie o fluxo de demonstração para um fluxo de entrada de aplicativo criado. Quando você inicia o aplicativo, o Amazon Kinesis Data Analytics lê o fluxo de demonstração continuamente e insere linhas no fluxo de entrada de aplicativo . Consulte esse fluxo de entrada de aplicativo no código do aplicativo.

        

     • Pré-processamento de registros com AWS Lambda: Essa opção é onde você especifica um AWS Lambda expressão que modifica os registros no fluxo de entrada antes da execução do código do aplicativo. Neste exercício, deixe a opção Disabled selecionada. Para obter mais informações sobre o pré-processamento do Lambda, consulte Pré-processar dados usando uma função do Lambda.

   Após fornecer todas as informações desta página, o console enviará uma solicitação de atualização (consulte UpdateApplication) para adicionar a configuração de entrada ao aplicativo.

3. Na página Source, escolha Configure a new stream.

4. Escolha Create demo stream. O console configura a entrada do aplicativo fazendo o seguinte:

   • O console cria um fluxo de dados do Kinesis chamado kinesis-analytics-demo-stream.

   • O console preenche o fluxo com dados de exemplo de códigos das ações.

   • Usando a ação de entrada DiscoverInputSchema, o console infere um esquema lendo os registros de exemplo no fluxo. O esquema inferido é o esquema para o stream de entrada no aplicativo criado. Para obter mais informações, consulte Configuração de entrada do aplicativo.

   • O console mostra o esquema inferido e os dados de exemplo que ele leu na origem de streaming para inferir o esquema.

   O console exibe os registros de exemplo na origem de streaming.

   

   O seguinte é exibido na página do console Stream sample:

   • A guia Amostra de fluxo bruto mostra os registros de fluxo bruto amostrados pela DiscoverInputSchema API ação para inferir o esquema.

   • A guia Formatted stream sample mostra a versão tabular dos dados na guia Raw stream sample.

   • Se selecionar Edit schema, você poderá editar o esquema inferido. Neste exercício, não altere o esquema inferido. Para obter mais informações sobre a edição de um esquema, consulte Trabalho com o editor de esquema.

     Se selecionar Rediscover schema, você poderá solicitar que o console execute DiscoverInputSchema novamente e infira o esquema.

5. Escolha Save and continue.

   Agora, você tem um aplicativo com a configuração de entrada adicionada a ele. Na próxima etapa, você adiciona SQL código para realizar algumas análises no fluxo de entrada de dados no aplicativo.