ASA: Encountered error when communicating with EventHub: Exceeded the maximum number of allowed receivers per partition in a consumer group which is 5
https://stackoverflow.com/questions/74305395/exceeded-the-maximum-number-of-allowed-receivers-azure-stream-analytics-job-con I have read and followed the suggestion from the link above but the ASA still throws me the same error so I made some…
WebApp Stream logs not showing in Logs table AppServiceConsoleLogs
Hello, we have a linux WebApp, we have some logging that we can see in the Stream logs, but I can not see the logs in the AppServiceConsoleLogs table (is empty). Can somebody help with the issue?
Azure Stream analytics map column when writing parquet files
I was trying to use the capture feature for eventhub, writing Parquet files to blob storage. The UI passed me for creating a Azure Stream Analytics. I have a Json structure in the eventhub, which contains an object field, like the…
Stream Analytics job is lock
Hi, my SAJ is blocked, not working, I can't see inputs, outputs or query. The controls on the main service page (Start job; Delete; Move) are disabled. What could be wrong? Thanks JD
Stream analytics
The Stream Analytics job works, it's just that it does not show in the Cosmos DB container. I am not sure whether it is my partition key that is incorrect.
Azure stream analytics
I get this error when I want to display the data generated from this script
User defined function doesn´t work because I use split method
I created user defined function in Azure stream analytics but this function doesn´t work because I use split method in my function Erorr code: Function 'splitandconverthex' resulted in an error: 'TypeError: Unable to get property 'split' of undefined…
How to fix Microsoft Telcodata generator lab?
Hi, I just wanted to let you know that Microsoft's Telcogenerator.zip file is not work. Its not generating data once it used to when endpoint is been updated in the .exe config file. please look into the…
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 \ …
How do I pass all the JSON packets received in that particular tumbling window to the Javascript UDF function from the Azure Stream Analytics Query?
Below is my Azure Stream Analytics query. In this query, I have set the tumbling window for 10 seconds, and whatever data I will be receiving in these 10 seconds, I wanted to pass these complete packets in the "AggrFunction(IotMessage)" UDF…
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…
Can Stream Analytics Update values in an existing table in Cosmos DB PostgreSQL?
Hi, I was wondering if I could update data in Cosmos DB for PostgreSQL table using Stream Analytics. I receive data through IOTHub and instead of adding rows of data I need to update values in different rows and columns. It seems that Stream Analytics…
Aggregate within 7 days
Hi All, I have a stream analytics query that aggregates data within 7 days, but seems it is not getting data through in the output (cosmos db). Here is my sample query: SELECT a.Name, b.TotalAmt FROM table1 AS a LEFT OUTER JOIN ( SELECT Id, SUM(Amount)…
"custom autoscale" in Stream Analytics Job is not enabled
When Custom auto scale is enabled in Stream Analytics?
How to create azure data explorer output connection from stream analytics with az cli command
Hi Team, Could you please let us know how we can create output connection from stream analytics to azure data explorer with the help of AZ cli command or arm template ? I did not find the az cli command for azure data explorer output from stream…
Are Azure Stream Analytics Job Resilient and zone redundant
Hi, I am looking at moving the current solution I have designed for a client to a production ready service. We are using a number of Azure resources from IaaS to PaaS. I am now looking at making this service production ready and need to understand the…
Is there anything else to pay attention to when using GetArrayElements() function?
I create a UDF in Azure Stream Analysis,but there was an error when I called it, as follows: //ExtractDynamicFields(inputData) is the UDF,and it return the array type CROSS APPLY GetArrayElements(ExtractDynamicFields(event)) AS arrayElement //error…
Como enviar a saída do Stream Analytics para o Power BI
Ola pessoal, Estou tentando enviar dados do Stream Analytics para o Power BI. Gostaria de saber se o usuário que estou usando no Azure tem que ser o mesmo que tem a conta no Power BI. Abs
Stop , Delete actions disabled in portal for running Stream Analytics
After start of Stream Analytics job I've created , there is no possibility to Stop it. And i lost access to all information related to the job. Based on log job started succesfully (and it is doing what is supposed to do). In IAM I'm reflected as owner…
How can I output data to output sources with the same alias?
My stream analysis job generates different types of data when processing input source data. How can I sequentially output these data to output sources with the same alias? Or what other methods are there?If I cannot output to an output source with the…