Schedule a pipeline in Azure Synapse analytics
How can I schedule a trigger pipeline in Azure Synapse analytics to run every 30 minutes, but avoid starting when another pipeline is running or at certain specified times (such as between 1 am to 3 am)? I am seeking guidance on the best approach for…
Upsert Data in SQL Server Using Synapse Notebook and Pyspark
How do I use pyspark in a synapse notebook to upsert data in SQL Server? I am able to read the table with the following code: df = spark.read.jdbc(url=jdbc_url, table="Dim.table_name", properties=properties) But I am not sure how to upsert…
Restore KekIdentity in Synapse Workspace
Hi, We deleted the managed identity for our synapse workspace that was the KekIdentity And now, when we open the workspace, none of the resources will load. I don't see any documentation on how to restore the KekIdentity for the Azure…
Missing "smallrc" DB role from Synapse Analytics dedicated SQL pools
Hi All, I am a data engineer. Since yesterday we have observed that the "smallrc" DB role is missing from all synapse dedicated sql pools in all our environments (dev/stage/prod). All our synapse instances are provisioned in the AU East Azure…
Facing issues to connect with synapse workspace/azure sql db via oauth
I want to connect to and access my Synapse Workspace and SQL Pool using OAuth. For this purpose, I have created an app in Azure and assigned the following API permissions: Microsoft Graph: Directory.Read.All (Delegated) Directory.ReadWrite.All…
transformation changes in silver and bronze layer
Hi , what transformation takes place between silver and gold layer .i.e have loaded data in bromze layer whichn is my bronze layer and i transformed data here ... then what will happend to silver to gold layer apart from pk,fk joins and all
how to update Azure Synapse spark pool with an exiting configuration in workspace
I have an existing Synapse configuration that has been set from the Synapse studio. Now I have a new spark pool created and want to bind that configuration to the pool. On the portal, it can be set on the sparkpool. But what is the programmatic way to do…
Azure Synapse Analytics Serverless - cross database queries
Synapse Analytics Serverless. Scenario: a ViewB in DatabaseB points to ViewA in DatabaseA where same user is created on both databases on order to read ViewB data Question is how we can hide user access on DatabaseA so only ViewB is reachable but…
Why is FailureWebHook not executed in this case?
Please consider the following pipeline. The Execute Pipeline activity failed, so the ProcessTMONData notebook was skipped. Why was the failure webhook not triggered, as it's supposed to trigger when EITHER: ForEachEndpoint fails ProcessTMONData is…
Datetime2 error when querying parquet file produced from Synapse copy activity from OData Business Central Source (data seems to be changed from 0001-01-01 to 0000-12-30)
I have a pipeline running a copy activity to copy data from Business Central OData source to parquet file everyday. Everything works fine before 16/07/2024 but problem arises starting from 17/07/2024. The parquet file no longer be able to query from…
Azure Synapse "Message Type Not Found" error when running stored procedure: Appears when lines of code reach certain line length
Hi, We need some technical guidance from either a Azure Synapse specialist to resolve an issue which we are unable to understand / fix despite running through the sql logic bit-by-bit, line-by-line. Any guidance or help would be much appreciated. We have…
Azure Synapse Analytics Data Flow: How do the Table Actions and Update Methods work & can you conditionally Truncate with 1 Data Flow?
I am working in Azure Synapse Analytics and making a dataflow, but I'm struggling with understanding some things. (I'm using Azure Data Lake Storage Gen 2 and Delta file for my sink) For the sink activity: what is the difference between the update…
Getting error like 'FAILED CLUSTER CREATION' for apache spark pool compute cluster
Apache spark pool compute cluster is not running since 20th July. error show sin 'LivySessionCreationTimeoutException: Livy session creation timed out.' has anybody else faced this issue? I have created a new cluster and tried but that's showing the same…
Error due to cloned Pipeline after it was renamed and has been published
Hi all I cloned a pipeline and then renamed it and published the changes: So Now I have FolderLive PipelineLIVE PipelineTEST FolderTEST Perfect! so all published and ready for the next step of moving PipelineTEST in to FolderTEST and publish. …
Data is missing from management API using service principle. ex:resources
I have a requirement to load datasets from management.Azure.com (Management API), for example: Resources, Assessments, Tasks, and Secure Score. I have created a service principal in app registration and have been able to obtain the access token. However,…
Synapse Link for Dataverse-SYN-806: Default storage container in Synapse workspace is not accessible error while enbling tables
Hi, I'm trying to setup a synapse link via dataverse to F&O. I'm able to setup the connection but when I enable tables sync status is throwing out error . Error details - SYN-806: Default storage container in Synapse workspace is not…
Synapse data warehouse and use
Hi friends, can we build a data mart kind of architecture for multiple domains in Synapse? How to built data marts for specific business entities in Synapse?
How to make manual failover to Azure Gen2 namespace enabled for disaster recovery plan
As a disaster recovery drill test for Azure adls namespace enabled accounts . I could see failover option for blob storage and but for adls namespace enabled accounts the failover option is disabled. Can anyone help in know how to do failover for Azure…
Problem with Power BI
Hi I am having a problem linking a button with a bookmark. When I click on the button nothing happens. I have referenced chatgpt and I can't get a straight answer. Thank you
Connect to eventhub using Managed service identity (MSI) from Azure synapse analytics
I am trying to write the data to azure eventhubs from the azure synapse analytics notebook in scala using Managed service identity (MSI). Can you please help me with code for that. Note that i was able to successfully connect using the SAS key.