Kzryzstof
Kzryzstof

Reputation: 8392

How to pass Tumbling Window parameters to a Data Factory pipeline in the Data Factory UI?

I have defined a pipeline in Azure Data Factory with a Tumbling Window trigger, as seen below:

Pipeline with the trigger

I would like for my activities to receive the Tumbling window parameters (trigger().outputs.windowStartTime and trigger().outputs.windowEndTime) however I did not find any examples in the documentation showing how to do this in the UI.

Question

How can I pass the Tumbling Window parameters to a Data Factory pipeline in the Data Factory UI?

Upvotes: 6

Views: 5432

Answers (3)

Tony
Tony

Reputation: 311

This is because you set @trigger().outputs.windowStartTime and @trigger().outputs.windowEndTime in the variable. In fact, you should set them in the parameter, like this:

enter image description here

![enter image description here enter image description here

Please let me know if still facing issue.

Upvotes: 1

CHEEKATLAPRADEEP
CHEEKATLAPRADEEP

Reputation: 12788

This answer is out of date. Parameters can be added directly in the UI - see my answer above.

Note: You cannot pass the Tumbling Windows parameters to a Data Factory pipeline in the ADF UI.

You need to pass the tumbling window parameters by following steps:

First create a Tumbling window trigger as per your requirement.

On the bottom left corner, you will find the "Triggers" tab => Click on Triggers and select the created trigger and click on "Code" and replace the parameters.

enter image description here

To use the WindowStart and WindowEnd system variable values in the pipeline definition, use your "MyWindowStart" and "MyWindowEnd" parameters, accordingly.

enter image description here

For more details, refer "MSDN" thread, which addressing similar issue.

Hope this helps.

Upvotes: 2

Steve Homer
Steve Homer

Reputation: 3922

Assuming the pipeline that you're triggering is already paramaterised then you're nearly there.

When adding the trigger you'll see a second screen to pass parameters from the trigger.

enter image description here

You can then add your functions prefixed with @. So:

@trigger().outputs.windowStartTime
@trigger().outputs.windowEndTime

If you need to call a function on the parameter before you pass it you can do that too

@addHours(trigger().outputs.windowEndTime,1)

Upvotes: 5

Related Questions