pipelines
13 TopicsUisng Fabric jupyter notebook to load/push data from/to Snowflake
Hello Farbic Community I'm new to using Fabric and am exploring its capabilities. I understand that we can load data from Snowflake into a Fabric Notebook via Data Lakehouse. I'm curious if it's possible to use a Python script in a Fabric notebook to directly load data from Snowflake into the notebook without involving a data lakehouse. In addition to direct data import from Snowflake, I'm also interested in whether data can be pushed back to Snowflake. If direct data import/export to and from Snowflake isn't feasible with a Python script in a Fabric notebook, is it possible to accomplish this using Dataflow or Data Pipeline? I would appreciate any suggestions and guidance.2KViews0likes4CommentsPushing data into warehouse
We have a user platform that fires a function to log every user action (button press) using JavaScript and currently saves this to Dataverse. This is not scalable and I would like this to be within a datawarehouse/lake for future manipulation/reporting. Is there a programatic way to directly create records in a fabric warehouse/lake ?Solved1.3KViews0likes3CommentsStarter pool limitation alternative workarounds
Starter pool limitation: Workspaces with managed virtual networks (VNets) can't access starter pools. This category encompasses workspaces that use managed private endpoints or are associated with a Fabric tenant enabled with Azure Private Links and have executed Spark jobs. Such workspaces rely on on-demand clusters, taking three to five minutes to start a session from mentioned article https://learn.microsoft.com/en-us/fabric/security/security-managed-private-endpoints-overview#limitations-and-considerations Is there any workaround or alternative for this ?What is a recommended best practice around Spark workloads?2.8KViews0likes4CommentsDeployment pipeline troubles
Hello I some questions about deployment pipeline. I using notebooks to integrate data in m'y lakehouse. When a deploy my deployment pipeline to my prod workspace, the lakehouse in the notebooks is still thé lakehouse of my development workspace. How can i make the change ? Then when i deploy my datawarehouse whitch is created with stocked procedures, i Can not open my pipeline whitch contain my stocked procedures from my production workspace. After Reading a lot i think that there IS a lot of things whitch are in preview but if you are some informations. It will be great. Thank for your help. Ben2.7KViews0likes8CommentsUnable to create a shortcut in Fabric to my serverless Synapse with private endpoints ADLS Gen 2 DL
I have a serverless Synapse deployment with a bunch of parquet and CSV files in ADLS Gen 2 storage account for my synapse. The synapse is configured to use private endpoint connections. I have created a new PE and approved it for the storage account. When I try to create a shortcut in Fabric it fails no matter what connection method that I chose saying invalid credentials and I am unable to find any further detail/error messages to help me resolve this issue. Please help! I have also tried connecting via spark and get unauthorized access errors despite ensuring my user has the Storage Blob Data Contributor role. Spark error: Caused by: Operation failed: "This request is not authorized to perform this operation.", 403, HEAD, ... fyi- My synapse deployment config follows the published End to End Analytics: https://learn.microsoft.com/en-us/azure/architecture/example-scenario/dataplate2e/data-platform-end-to-end?tabs=portal3.7KViews0likes5Commentsdeleting duplicate rows in lakehouse
Hi, i developed a data pipeline in Fabric Data Factory that copy Parquet file data into a fabrick lakehouse table. After loading the data, i need to remove duplicates from the lakehouse table. I tried to add a script step in the pipeline, but it seems to only allow connections to warehouse and not lakehouse. I also tried to create a notebook using spark sql and run a sql script against the lakehouse table like this: ;WITH Dups AS ( SELECT *, ROW_NUMBER() OVER(PARTITION BY cmal.Id ORDER BY cmal.CreationTime) AS [Rank] FROM dbo.AuditLog cmal) DELETE Dups FROM Dups WHERE Dups.Rank > 1 GO but i get the following error: no viable alternative at input 'with' so i don't think spark sql recognizes the 'with' funciton. Does anyone know of another way to delete duplicates from a lakehouse table in Fabric? thanks scottSolved6.9KViews0likes5Comments- 2.4KViews0likes4Comments
Add new and last modified records to a delta table in Lakehouse Fabric from parquet files
I have some parquet files related to GeneralLedger records in a Lakehouse and I want using pipeline to add only new and last modified records to a Delta table. What should I do? I used combination of lookup activity and copy data, but doesn't work for me. Any idea?2.3KViews0likes4Comments