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á.
Input
Ao configurar a entrada para um aplicativo do Kinesis Data Analytics baseado em SQL, você especifica a origem do streaming, o nome do stream no aplicativo que é criado e o mapeamento entre os dois.
Conteúdo
- InputSchema
-
Descreve o formato dos dados na origem do streaming e como cada elemento de dados é mapeado para as colunas correspondentes no stream do aplicativo que está sendo criado.
Também é usado para descrever o formato da fonte de dados de referência.
Tipo: objeto SourceSchema
Obrigatório: Sim
- NamePrefix
-
O prefixo do nome a ser usado na criação de um fluxo no aplicativo. Suponha que você especifica um prefixo “
MyInApplicationStream”. O Kinesis Data Analytics cria um ou mais (de acordo com a contagem deInputParallelismespecificada) fluxos na aplicação com os nomes “MyInApplicationStream_001”, “MyInApplicationStream_002” e assim por diante.Tipo: string
Restrições de tamanho: tamanho mínimo 1. Comprimento máximo de 32.
Padrão:
[^-\s<>&]*Exigido: Sim
- InputParallelism
-
Descreve o número de fluxos do aplicativo a serem criados.
Tipo: objeto InputParallelism
Obrigatório: Não
- InputProcessingConfiguration
-
O InputProcessingConfiguration para a entrada. Um processador de entrada transforma registros à medida que são recebidos do fluxo, antes do código SQL do aplicativo ser executado. No momento, a única configuração de processamento de entrada disponível é InputLambdaProcessor.
Tipo: objeto InputProcessingConfiguration
Obrigatório: Não
- KinesisFirehoseInput
-
Se a origem do streaming for um fluxo de entrega do Amazon Kinesis Data Firehose, identificará o ARN do fluxo de entrega.
Tipo: objeto KinesisFirehoseInput
Obrigatório: Não
- KinesisStreamsInput
-
Se a origem do streaming for um fluxo de dados do Amazon Kinesis, identificará o nome de recurso da Amazon (ARN).
Tipo: objeto KinesisStreamsInput
Obrigatório: Não
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:
