Para novos projetos, recomendamos que você use o novo Managed Service for Apache Flink Studio em vez do Kinesis Data Analytics para aplicativos 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á.
Input
Ao configurar a entrada do aplicativo, você especifica a fonte de transmissão, o nome do fluxo no aplicativo que foi criado e o mapeamento entre os dois. Para obter mais informações, consulte Configuração de entrada do aplicativo.
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
-
Prefixo de nome a ser usado na criação de um fluxo no aplicativo. Suponha que você especifique um prefixo "”MyInApplicationStream. Em seguida, o Amazon Kinesis Analytics cria um ou mais (de acordo com
InputParallelisma contagem especificada) streams no aplicativo com os nomes MyInApplicationStream "_001,” "MyInApplicationStream_002" e assim por diante.Tipo: sequência
Restrições de tamanho: tamanho mínimo 1. Comprimento máximo de 32.
Obrigatório: Sim
- InputParallelism
-
Descreve o número de fluxos do aplicativo a serem criados.
Os dados de sua origem são roteados para esses fluxos de entrada no aplicativo.
(consulte Configuração de entrada do aplicativo.
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. Atualmente, 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 Firehose, identifica o ARN do fluxo de entrega e uma função do IAM que permite que o Amazon Kinesis Analytics acesse o fluxo em seu nome.
Nota:
KinesisStreamsInputouKinesisFirehoseInputé necessário.Tipo: objeto KinesisFirehoseInput
Obrigatório: Não
- KinesisStreamsInput
-
Se a origem do streaming for um fluxo do Amazon Kinesis, identifica o nome de recurso da Amazon (ARN) do fluxo e uma função do IAM que permite que o Amazon Kinesis Analytics acesse o fluxo em seu nome.
Nota:
KinesisStreamsInputouKinesisFirehoseInputé necessário.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:
