Issue with max block count in Azure Data Lake Gen2
Starting from 03/02/23 I have noticed that my Stream Analytics Job has been creating more files per day than before. Looking through the files' properties I discovered that every file maxes out at 10000 blocks and then the SA Job creates another one,…
How to hide a column in Azure Stream Analytics Data Preview
Is there anyways to hide the column in Azure Stream Analytics Data Preview? In my case, I want to hide column "properties" in data preview. Thanks!
Difference between schema.history and database.history in mysql connector
I set up kafka, mysql and debezium in my computer successfully. However, i have still not understood about the difference between database.history.kafka.topic and schema.history.internal.kafka.topic. Below is my connector: Please help me explaining the…
Azure Function concurrency issues
I have multiple azure functions running at the same time and creating multiple instances of each.The parameters are also passed in parallel that means at one time all the azure function urls will be hit at once.Below is an example of how I am…
ASA run same code with different result?
The following 2 codes get different result: FROM IotBaseInput as event CROSS APPLY GetArrayElements(event.monoEvent) AS arrayElement CROSS APPLY GetRecordProperties(arrayElement.arrayvalue) AS recordProperty Where recordProperty.PropertyName !=…
Using multiple, mixed length Windows in Stream analytics query results in high (100%) SU memory utlization
I want to use Windows to collect both 3-hour and 1 day max, min, average and count of certain device messages arriving to iot hub. If I use both windows, as in code snippet, SU memory usage goes to 100%. If I use only one Window (does not matter which…
Facing error while creating Azure Stream Analytics job service
Hi Team, I am getting error while deploying an Azure Stream Analytics instance from UI. I am not using any ARM template. It says "Your deployment failed" and throws the below error. { "code": "NotFound", …
Azure Stream Analytics output config json as managed identity to service bus queue
Hello I have an ASA job that is using managed identity to send messages to a service bus queue (this is working) however when trying to deploy changes the template that is generated expects parameters for SharedAccessPolicyName, which to my understanding…
spark.readStream.text() text file from adls gen2 in databricks
file_path = "adl://<account-name>.dfs.core.windows.net/<container>/<path>/*.txt" streaming_df = spark.readStream \ .schema(schema) \ .text(file_path) query = streaming_df_transformed.writeStream \ …
Azure Stream Analytics Test Query Does not work correctly with "WITH" clauses
Here is my query: WITH Stage1 AS ( SELECT records.ArrayValue.time as Recordedtime, records.ArrayValue.properties.flows as flows FROM [insights-logs-networksecuritygroupflowevent] as n CROSS APPLY GetArrayElements(n.records) AS…
How can I force cast JSON-number values to float?
Exactly what the image shows. I have numbers that not always have decimal numbers and I need them to be float. As the image shows, this doesn't work today. What am I doing wrong?
Low level mistake - mismatch in naming found in Stream Analytics
I have been using Stream Analytics. I got iothub-pj001, iothub-pj005 and iothub-pj009 in the Iothub and these are set as input in the Stream Analytics. I found that I cannot find the option of iothub-pj001 last night when I was trying to add a new…
Not able to use ML model to post and retrieve data
Hi I am using ml library model that results into below output on test page. False Alarm Prediction using Two Class Decision Forest [Predictive Exp.]' test returned ["8/10/2023 6:15:00 AM","User…
Setup edge hub input for azure stream analytics using the azure cli or python SDK
I am trying to create an azure stream analytics job using azure cli or python SDK with both input and output as edge hub. I tried using None and GatewayMessageBus as the input types but both of them did not work. It gives an error message: (BadRequest)…
watermark keeps increasing and event are not processed in Stream Analytics
I have IoT package data coming in from Event Hub to Stream Analytics and then outputted to a Delta Lake before switching to Delta Lake, I had output as CSV and it worked fine, no watermark delays, resource utilization was stable and low. After switching…
Azure Stream Analytic at-least-once guarantees is not 100% accurate
I have Azure Stream Analytic (ASA) that process data from the event hub as input. And this job is for the finance biz so it is heavily based on Event Delivery Guarantees at least once of Azure Stream Analytic. But recently we found out that some data…
Connecting Streamanalytics to IoTHub
Hi all, We're facing the issue that since 2 days ag We're getting the problem that "Stream Analytics job has validation errors: Unable to connect to IoT Hub using connection string. Please make sure you have configured the IoT Hub input correctly. …
Connection failed when connectiong to a Storage account in Vnet
I am trying to use storage as an input for the Stream Analytics job. For the storage account the access for the job is enabled and Managed Identity has a Storage Blob Data Contributor role. Still, when adding input I get successful connection but…
MS Stream scrubbs poorly
Is there a setting to make it scrub faster? Sort of hard to see what's going on when it takes 5 second to load a frame.
Why did scaling not help on delayed Stream Analytics outputs?
Hello :) We have an Azure Function that sends a lot of data in a single format to an Event Hub, which sends it to a Stream Analytics, which forwards the data to multiple outputs. This have worked very good for a long time, but a couple of days ago I…