Automating Daily File Transfer and Storage Using Azure Logic Apps for Daimler Project
I am working on automating a file transfer process using Azure Logic Apps, where a file is sent from one user to another twice daily, at 5 AM and 5 PM. The goal is to automatically store the files in specific Azure Blob Storage locations based on the time they are received. Here's what I need to achieve:
At 5 AM: Store the received file in the Azure Blob Storage container path: /rk/test. At 5 PM: Store the received file in the Azure Blob Storage container path: /rk/test/archive What I Have Done So Far: I've set up a Logic App with a Recurrence trigger to run at 5 AM and 5 PM daily. I'm using the Outlook 365 connector to fetch emails with attachments sent by a specific person. I've also added a Blob Storage connector to upload the file to the required storage location. The Challenge: I’m struggling to implement the logic to distinguish between the 5 AM and 5 PM files so that they are routed to the correct storage paths. Specifically, I'm unsure how to:
Check the current time and apply conditional logic to route the file to the correct Blob Storage path. Ensure that the Logic App runs as intended and processes files sent at these specific times without missing any or routing them incorrectly.
I've set up a Logic App with a Recurrence trigger to run at 5 AM and 5 PM daily. I'm using the Outlook 365 connector to fetch emails with attachments sent by a specific person. I've also added a Blob Storage connector to upload the file to the required storage location.
You need to implement Condition action to check the timings like 5 AM or 5 PM and also convert the time accordingly as in my case I am using IST time zone.
I am using two condition action and below given workflow to get the expected response.
{
"definition": {
"$schema": "https://schema.management.azure.com/providers/Microsoft.Logic/schemas/2016-06-01/workflowdefinition.json#",
"actions": {
"Condition": {
"actions": {
"For_each_1": {
"actions": {
"For_each": {
"actions": {
"Create_blob_(V2)": {
"inputs": {
"body": "@base64ToBinary(items('For_each')?['contentBytes'])",
"headers": {
"ReadFileMetadataFromServer": true
},
"host": {
"connection": {
"name": "@parameters('$connections')['azureblob']['connectionId']"
}
},
"method": "post",
"path": "/v2/datasets/@{encodeURIComponent(encodeURIComponent('AccountNameFromSettings'))}/files",
"queries": {
"folderPath": "/sample-container/rk/test/",
"name": "@items('For_each')?['name']",
"queryParametersSingleEncoded": true
}
},
"runtimeConfiguration": {
"contentTransfer": {
"transferMode": "Chunked"
}
},
"type": "ApiConnection"
}
},
"foreach": "@item()?['attachments']",
"type": "Foreach"
}
},
"foreach": "@body('Get_emails_(V3)')?['value']",
"type": "Foreach"
}
},
"else": {
"actions": {
"Condition_1": {
"actions": {
"For_each_3": {
"actions": {
"For_each_2": {
"actions": {
"Create_blob_(V2)_1": {
"inputs": {
"body": "@base64ToBinary(items('For_each_2')?['contentBytes'])",
"headers": {
"ReadFileMetadataFromServer": true
},
"host": {
"connection": {
"name": "@parameters('$connections')['azureblob']['connectionId']"
}
},
"method": "post",
"path": "/v2/datasets/@{encodeURIComponent(encodeURIComponent('AccountNameFromSettings'))}/files",
"queries": {
"folderPath": "/sample-container/rk/test/archive",
"name": "@items('For_each_2')?['name']",
"queryParametersSingleEncoded": true
}
},
"runtimeConfiguration": {
"contentTransfer": {
"transferMode": "Chunked"
}
},
"type": "ApiConnection"
}
},
"foreach": "@item()?['attachments']",
"type": "Foreach"
}
},
"foreach": "@body('Get_emails_(V3)')?['value']",
"type": "Foreach"
}
},
"else": {
"actions": {}
},
"expression": {
"and": [
{
"equals": [
"@int(formatDateTime(convertTimeZone(utcNow(), 'UTC', 'India Standard Time'), 'HH'))",
17
]
}
]
},
"type": "If"
}
}
},
"expression": {
"and": [
{
"equals": [
"@int(formatDateTime(convertTimeZone(utcNow(), 'UTC', 'India Standard Time'), 'HH'))",
5
]
}
]
},
"runAfter": {
"Get_emails_(V3)": [
"Succeeded"
]
},
"type": "If"
},
"Get_emails_(V3)": {
"inputs": {
"host": {
"connection": {
"name": "@parameters('$connections')['office365']['connectionId']"
}
},
"method": "get",
"path": "/v3/Mail",
"queries": {
"fetchOnlyFlagged": false,
"fetchOnlyUnread": true,
"fetchOnlyWithAttachment": true,
"folderPath": "Inbox",
"importance": "Any",
"includeAttachments": true,
"top": 10
}
},
"runAfter": {},
"type": "ApiConnection"
}
},
"contentVersion": "1.0.0.0",
"outputs": {},
"parameters": {
"$connections": {
"defaultValue": {},
"type": "Object"
}
},
"triggers": {
"Recurrence": {
"evaluatedRecurrence": {
"frequency": "Day",
"interval": 1,
"schedule": {
"hours": [
"5",
"17"
],
"minutes": [
0
]
},
"timeZone": "India Standard Time"
},
"recurrence": {
"frequency": "Day",
"interval": 1,
"schedule": {
"hours": [
"5",
"17"
],
"minutes": [
0
]
},
"timeZone": "India Standard Time"
},
"type": "Recurrence"
}
}
},
"parameters": {
"$connections": {
"value": {
"azureblob": {
"connectionId": "/subscriptions/0e8*******5e7c/resourceGroups/*********/providers/Microsoft.Web/connections/azureblob",
"connectionName": "azureblob",
"id": "/subscriptions/0e8********5e7c/providers/Microsoft.Web/locations/eastus/managedApis/azureblob"
},
"office365": {
"connectionId": "/subscriptions/0e8*********5e7c/resourceGroups/*******/providers/Microsoft.Web/connections/office365",
"connectionName": "office365",
"id": "/subscriptions/0e8*******5e7c/providers/Microsoft.Web/locations/eastus/managedApis/office365"
}
}
}
}
}
- How to output URL of Azure Logic Apps with Terraform?
- Trouble Passing Boolean Values in Azure Data Factory JSON Template
- Azure Logic App - For Each Key/Value Pair (Answered!)
- how to create new json object using compose connector in logic app without change in order?
- Azure Logic App Error The 'FUNCTIONS_WORKER_RUNTIME' setting is required
- How can I add items from my parsed JSON into an existing array variable in Logic Apps
- Logic apps support of Hierarchical partition keys in Azure Cosmos DB
- How can you obtain the full URL of a HTTP triggered Logic App in the Azure Portal, if you can't use the designer?
- Automating Daily File Transfer and Storage Using Azure Logic Apps for Daimler Project
- logic apps, refresh a dataset of power bi
- Logic App to call Azure SQL stored procedure passing datetime param
- Add & Delete a secret into Azure KeyVault using logic app standard
- CTRL+F / search string in code of multiple logic app workflows at once
- How to dynamically create a CSV out of parsed JSON in a Logic App
- How to call Logic App from azure synapse analytics?
- Access Logic App Parameters in PowerShell script code in Standard workflows
- Logic Apps adding Schema to X12 Agreement
- How to check json and do filtering in Logic App
- The execution of template action 'Response' is skipped: the client application is not waiting for a response from service
- Is it possible to grab a value from a blob (uploaded csv to container) and pass it to a Logic App?
- How to call a python script from a logic app to parse and write data to an azure sql database
- Parsing JSON Array of Strings in Logic Apps
- logic app local function unable to resolve service
- Can't assign array from JSON to a new variable and return in reponse in Azure Logic App
- Filtering child array by attribute in Logic Apps
- SQL query to group parameters into same column where ID is the same
- Azure Logic Apps - Condition Notify issue
- Nested For Each creating duplicates in Logic App
- Azure Logic Apps - Variables Array
- Logic app standard - service bus session problems