data engineering
14 TopicsIngest Data from Streaming API
I am trying to ingest data into my Lakehouse from a streaming API (https://developer-specs.company-information.service.gov.uk/streaming-api/guides/overview) I currently do this using a Function App that connects to the API and packages and stores files every 8 minutes. The Function then reconnects using the latest timestamp processed. This is the recommended method in the above link. How can I recreate this in Fabric pipelines/eventstream to ingest the streaming data into OneLake? ThanksSolved20KViews0likes6CommentsEvent Stream unable to load the data into Lakehouse\ KQL
Hi, Looking some advice and help. I have a scenario. IOT devices messages and events data pointed to event hub (having 3-4 different message types). Without using the eventprocessing able to load the data into either lakehouse\ KQL by using event stream. But partial data loaded. When tried to use the eventprocessing with Manage Fields and Filter operations then the data is loading into both lakeshouse and KQL. Created the tables seperately and also tried to load but no luck. I am using filter operation as " column1 equals abc". Appreciate any quick help..8.6KViews0likes2CommentsHow to create event stream, reflex and connect it to pipeline.
Hi All, We have pipeline which reads multiple zip files and then execute these multiple zip files parallely to generate output. Right now this pipeline is triggerd manually after placing multiple files in landing folder. We want to automate this process i.e. the moment the files are placed in landing folder the pipeline should be triggered automatically. To achieve this result, we have created event stream and reflex. But the thing is when the file is placed in landing folder, we can see this file in event stream as well as in reflex but the pipeline is not triggered. Can somebody guide us in how to achieve this automatic triggering of pipeline using event stream and reflex in Fabric and what could be the reason that we are not able to achieve the result. Thanks, DeepmalaSolved8.5KViews0likes1CommentAnomaly Detection
Hi, The walkthrough for real-time analysis in Fabric has the query below as an example of anomaly detection in taxi driver tips in New York: nyctaxitrips | lookup (Locations) on $left.PULocationID==$right.LocationID | where Borough == "Manhattan" | make-series s1 = avg(tip_amount) on tpep_pickup_datetime from datetime(2022-06-01) to datetime(2022-06-04) step 1h | extend anomalies = series_decompose_anomalies(s1) | render anomalychart with (anomalycolumns=anomalies) What bothers me is that the detection is made over an average, so we are not really detecting the anomaly, we are detecting the hour inside which the anomaly happened. The make-series only work with an aggregation function. Is it possible to use series_decompose_anomalies to detect individual anomaly values, instead of aggregated anomaly values? How could we use the make series without aggregation? The example contained in the description page of the function series_decompose_anomalies is about web traffic and makes complete sense, because there is no anomaly on an individual value, it only exists on an aggregation. But for taxi driver tips, there is one anomaly and we can't find it aggregating. Of course I could use separate queries over the hours pointed as anomaly to discover which is the anomaly value, but I was willing to find a solution to see the anomalies in a chart with a query. Am I wrong? Is my concept wrong? Kind Regards, Dennes2.7KViews0likes3CommentsWhat File Types are supported in KQL DB ?
Hey community, I have a folder like this: year/month/Jan/ In Jan, I have sub folders like day 1, day 2, .... In these days folders, I have many files for instance day 1 has .json, .csv, and day 2 has .xml, .xlxs All of them have the same schema. So I have used a KQL to get them via pipeline and all of these different types of files were appended into a single table. I'd like to know what kinds of file formats it won't append, or not supported in a KQL DB. Thanks !Solved2KViews0likes1CommentGroup by on eventstream's lakehouse target doesn't aggregate numeric fields
Hi, The problem is: The fields are not available to apply an aggregation function. I can make a count, but I can't make a sum, avg or other. This was on the NYTaxi sample data, close the the existing real time walkthrough on Microsoft portal, but I included a lakehouse target (kusto and lakehouse, two targets) and this happened on the transformation for the lakehouse. Is this a bug, or did I miss something? The image below illustrate the problem. The only thing which appears is "partitionId": Kind Regards, DennesSolved23KViews0likes9CommentsDashboard Tile created from Kusto source doesn't refresh
Hi, The problem is exactly what the subject mentions. I think I may be hitting some limitation, something not suppported, but I need some clue about what it is to work around. The table from the semantic model uses direct query to the KQL database. The model is composed, but I ensured this table has no relationship with any other table using different storage models. What is causing this limitation (no refresh on tiles in a dashboard) and how to work around it? P.S: I'm aware report changes don't reflect on tiles, but that's not the problem. The test was done with no report change in the middle. Kind Regards, DennesSolved2.6KViews0likes4CommentsKQL Shortcut OneLake Option Missing
Hi there - We want to process data from Azure Data Explorer (Kusto). using Spark. I have created shortcut using this Create a database shortcut - Microsoft Fabric | Microsoft Learn . However, I don't see option for creating shorcut on top of KQL Shortcut database i.e I want to access this data under Lakehouse using externaltable option in order to process using spark. Created ShortCut using Azure Data Explorer (Kusto). Create a database shortcut - Microsoft Fabric | Microsoft Learn OneLakeAvailability Option: I can see OneLake Availablity Option for new kql database created in Fabric but it's missig in Above Screenshot Please suggest how to resolve the issue. Thanks, AbhiramSolved3.2KViews0likes4Comments