Para novos projetos, recomendamos que você use o novo Managed Service para Apache Flink Studio em vez do Kinesis Data Analytics for Applications. SQL O Managed Service for Apache Flink Studio combina facilidade de uso com recursos analíticos avançados, permitindo que você crie aplicativos sofisticados de processamento de stream em minutos.

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

AddApplicationInput

Adiciona uma origem de streaming ao seu aplicativo Amazon Kinesis. Para obter informações conceituais, consulte Configuração da entrada do aplicativo.

Você pode adicionar uma origem de streaming ao criar um aplicativo ou usar essa operação para adicionar uma origem de streaming depois de criar um aplicativo. Para obter mais informações, consulte CreateApplication.

Qualquer atualização da configuração, incluindo a adição de uma origem de streaming usando essa operação, resulta em uma nova versão do aplicativo. Você pode usar a DescribeApplicationoperação para encontrar a versão atual do aplicativo.

Essa operação exige permissões para executar a ação kinesisanalytics:AddApplicationInput.

Sintaxe da Solicitação

{
   "ApplicationName": "string",
   "CurrentApplicationVersionId": number,
   "Input": { 
      "InputParallelism": { 
         "Count": number
      },
      "InputProcessingConfiguration": { 
         "InputLambdaProcessor": { 
            "ResourceARN": "string",
            "RoleARN": "string"
         }
      },
      "InputSchema": { 
         "RecordColumns": [ 
            { 
               "Mapping": "string",
               "Name": "string",
               "SqlType": "string"
            }
         ],
         "RecordEncoding": "string",
         "RecordFormat": { 
            "MappingParameters": { 
               "CSVMappingParameters": { 
                  "RecordColumnDelimiter": "string",
                  "RecordRowDelimiter": "string"
               },
               "JSONMappingParameters": { 
                  "RecordRowPath": "string"
               }
            },
            "RecordFormatType": "string"
         }
      },
      "KinesisFirehoseInput": { 
         "ResourceARN": "string",
         "RoleARN": "string"
      },
      "KinesisStreamsInput": { 
         "ResourceARN": "string",
         "RoleARN": "string"
      },
      "NamePrefix": "string"
   }
}

Parâmetros da solicitação

A solicitação aceita os dados a seguir no formato JSON.

Elementos de Resposta

Se a ação tiver êxito, o serviço enviará de volta uma resposta HTTP 200 com um corpo HTTP vazio.

Erros

Consulte também

Para obter mais informações sobre como usar essa API em um dos AWS SDKs específicos da linguagem, consulte o seguinte: