Stream Analytics: caminho de saída dinâmico com base na carga útil da mensagem

Estou trabalhando em uma solução de análise de IoT que consome mensagens formatadas pelo Avro disparadas em um Hub IoT do Azure e (espero) use o Stream Analytics para armazenar mensagens no Data Lake e armazenamento de blob. Um requisito essencial é que os contêineres da Avro devem aparecer exatamente iguais no armazenamento, quando apresentados ao Hub IoT, para benefício dos consumidores downstream.

Estou com uma limitação no Stream Analytics com controle granular sobre a criação de arquivos individuais. Ao configurar um novo caminho do fluxo de saída, só posso fornecer data / dia e hora no prefixo do caminho, resultando em um arquivo para cada hora, em vez de um arquivo para cada mensagem recebida. O cliente requer contêineres de blob separados para cada dispositivo e blobs separados para cada evento. Da mesma forma, o requisito do Data Lake determina pelo menos uma convenção de nomenclatura são delineada pelo dispositivo, com arquivos separados para cada evento ingerido.

Alguém configurou com êxito o Stream Analytics para criar um novo arquivo toda vez que ele envia uma mensagem da entrada? Essa é uma limitação difícil do produto?

questionAnswers(1)

yourAnswerToTheQuestion