Uma empresa opera turbinas eólicas, estações meteorológicas e painéis solares que produzem telemetria. Os dispositivos estão distribuídos em vários locais e têm internet intermitente. Os cientistas de dados precisam de um pipeline de ingestão escalável, seguro e de alta taxa de transferência que armazene a telemetria bruta no Amazon S3 para detecção de anomalias e manutenção preditiva. Qual abordagem de ingestão satisfaz esses requisitos?

A ingestão de telemetria via MQTT para o AWS IoT Core é ideal para dispositivos com internet intermitente e distribuídos, pois o IoT Core é projetado para conectar bilhões de dispositivos e processar trilhões de mensagens de forma segura e escalável, suportando o protocolo MQTT. A configuração de uma regra do AWS IoT Core para rotear mensagens diretamente para um stream de entrega do Amazon Kinesis Data Firehose garante alta taxa de transferência e entrega automática para o Amazon S3, atendendo aos requisitos de armazenamento de telemetria bruta para detecção de anomalias e manutenção preditiva. As outras opções são menos eficientes ou adequadas: Usar um servidor web no EC2 com API HTTP introduz complexidade e não é otimizado para a natureza de telemetria de IoT e conectividade intermitente. Enviar dados do Kinesis Data Firehose para um Kinesis Data Stream e depois para o S3 adiciona uma camada desnecessária e custo, pois o Firehose pode gravar diretamente no S3. Enviar telemetria MQTT diretamente para um Kinesis Data Stream não é possível, pois o Kinesis Data Stream não suporta MQTT diretamente como entrada.