Azure stream Analytics Requête pour envoyer la sortie à différentes cibles

Question

Nous utilisons les analyses de flux Azure pour lire les messages du concentrateur IOT et écrire dans le magasin de données Lake Azure. L'entrée du travail d'analyse de flux est au format JSON et la sortie doit être au format CSV. Dans les analyses de flux, nous avons créé plusieurs puits de données de sortie qui pointent vers des répertoires différents dans le magasin de données Azure. Sur la base de l'un des champs de la chaîne JSON d'entrée, nous devons convertir l'entrée en CSV et écrire dans le collecteur de données de sortie respectif. Comment pouvons-nous réaliser cela dans la requête d'analyse de flux?

Answer 1

La conversion des formats se fera automatiquement. Tout ce que vous devez faire est de définir votre logique Stream Analytics.

Voici une requête très simple qui écrit des données dans deux sorties Data Lake différentes, en fonction de la valeur d'une variable dans l'entrée JSON.

SELECT * INTO datalake1 from myinput 
where windspeed<10 

SELECT * INTO datalake2 from myinput 
where windspeed>10 

Merci,

JS (Azure flux Analytics)