The source of my Copy activity is the result of calling a REST API and the Sink is a Azure SQL Table that I insert those records in it.
Now I want to know what records we just got inserted in that Sink so I can do some update statement on those records. So my question is how can I know what went into Sink so I can now update those records.
Having access to Records that went to Sink from a Copy Activity
90 Views Asked by UnskilledCoder At
1
There are 1 best solutions below
Related Questions in AZURE
- How to update to the latest external Git in Azure Web App?
- I need an azure product that executes my intensive ffmpeg command then dies, and i only get charged for the delta. Any Tips?
- Inject AsyncCollector into a service
- mutual tls authentication between app service and function app
- Azure Application Insights Not Displaying Custom Logs for Azure Functions with .NET 8
- Application settings for production deployment slot in Azure App Services
- Encountered an error (ServiceUnavailable) from host runtime on Azure Function App
- Implementing Incremental consent when using both application and delegated permissions
- Invalid format for email address in WordPress on Azure app service
- Producer Batching Service Bus Vs Kafka
- Integrating Angular External IP with ClusterIP of .NET microservices on AKS
- Difficulty creating a data pipeline with Fabric Datafactory using REST
- Azure Batch for Excel VBA
- How to authenticate only Local and Guest users in Azure AD B2C and add custom claims in token?
- Azure Scale Sets and Parallel Jobs
Related Questions in AZURE-DATA-FACTORY
- Difficulty creating a data pipeline with Fabric Datafactory using REST
- Accessing REST API Status Codes using Azure Data Factory Copy Activity (or similar)?
- Use an activity output as the step name to get additional info in ADF
- Exit loop condition when running the synpase notebooks based on metadata dependencies
- Azure Data Factory Copy Activity Only Importing First Row of XML file
- ADF Copy Activity from Source Azure Synapse Analytics Target ADLSGen2 Storage account
- Parmeter values not resolving in ADF
- How to copy XML files in a folder F1 based on whether its content is present on folder F2 (disregarding file names)
- Can I move an Azure Data Factory Pipeline to Azure DevOps?
- tsql functions like REPLACE() failing in azure data factory pipeline connected to salesforce
- Get the URL from C# script used in ssis
- Reading Unstructured Text from the entire file in Azure Data Factory
- Unable to PUT JSON using ADF Dataflow, the error is "the JSON value could not be converted to System.Collections.Generic.List"
- Manipulating Json in Azure Data Factory activities
- Couchbase Connector in ADF
Related Questions in AZURE-ADF
- Not able to generate ARM template
- Synapse Pipeline : DF-Executor-OutOfMemoryError
- ADF Error code 2011: Required property 'connectionString' is not provided in connection properties
- How to read XML file from web activity data in ADF
- Send email notification failure Azure data factory Pipeline not working (Web Job)
- Error while making dataset Connection with Snowflake in Azure ADF dataset
- How to install Azure ADF SelfHosted IR ON VM in quiet mode command line
- ADF - Failed To Send Request to Databricks Cluster
- Having access to Records that went to Sink from a Copy Activity
- What is the "Resource" when setting up a call to REST API from ADF with Managed Indentity
- ADF dynamic content using concat - need to embed commas inside of string for long list of columns
- ADF - replace switch statement for dataflows with a parameterized solution
- ADF Pipeline to Split an a JSON File with array of objects into seperate items in cosmos db
- Convert JSON file from google analytics to SQL table
- ADF-SQL server untrusted domain
Trending Questions
- UIImageView Frame Doesn't Reflect Constraints
- Is it possible to use adb commands to click on a view by finding its ID?
- How to create a new web character symbol recognizable by html/javascript?
- Why isn't my CSS3 animation smooth in Google Chrome (but very smooth on other browsers)?
- Heap Gives Page Fault
- Connect ffmpeg to Visual Studio 2008
- Both Object- and ValueAnimator jumps when Duration is set above API LvL 24
- How to avoid default initialization of objects in std::vector?
- second argument of the command line arguments in a format other than char** argv or char* argv[]
- How to improve efficiency of algorithm which generates next lexicographic permutation?
- Navigating to the another actvity app getting crash in android
- How to read the particular message format in android and store in sqlite database?
- Resetting inventory status after order is cancelled
- Efficiently compute powers of X in SSE/AVX
- Insert into an external database using ajax and php : POST 500 (Internal Server Error)
Popular Questions
- How do I undo the most recent local commits in Git?
- How can I remove a specific item from an array in JavaScript?
- How do I delete a Git branch locally and remotely?
- Find all files containing a specific text (string) on Linux?
- How do I revert a Git repository to a previous commit?
- How do I create an HTML button that acts like a link?
- How do I check out a remote Git branch?
- How do I force "git pull" to overwrite local files?
- How do I list all files of a directory?
- How to check whether a string contains a substring in JavaScript?
- How do I redirect to another webpage?
- How can I iterate over rows in a Pandas DataFrame?
- How do I convert a String to an int in Java?
- Does Python have a string 'contains' substring method?
- How do I check if a string contains a specific word?
Two methods come to mind
If the table has a timestamp of when the records were inserted then you could use that value to know which were just inserted.
Instead of putting the records directly in the final table put them in a staging table. Then you can either update as part of the insert to move them to the final table do the updates OR update them in staging table and then copy over to the final table. Just remember to truncate the staging table every run so it only has the new records.