{"id":12658,"date":"2018-08-16T17:48:01","date_gmt":"2018-08-16T12:18:01","guid":{"rendered":"https:\/\/www.inogic.com\/blog\/?p=12658"},"modified":"2022-07-21T12:06:25","modified_gmt":"2022-07-21T06:36:25","slug":"passing-data-from-dynamics-365-to-azure-service-bus-queue-using-pluginsworkflows","status":"publish","type":"post","link":"https:\/\/www.inogic.com\/blog\/2018\/08\/passing-data-from-dynamics-365-to-azure-service-bus-queue-using-pluginsworkflows\/","title":{"rendered":"Passing data from Dynamics 365 to Azure Service Bus Queue using Plugins\/Workflows"},"content":{"rendered":"

Introduction:<\/strong><\/h2>\n

Recently we had a business requirement where we need to pass data from Dynamics 365 CRM to Azure Service Bus queue through plugins and workflows. After some research and play around we found a solution for this.<\/p>\n

For this, we require an Azure Service Bus, an Azure function and a webhook. The CRM data can be delivered to azure portal using the webhook. The webhook is registered to connect to the azure function. When plugin\/workflow is triggered, webhook is called from the code which passes the data to azure function in JSON format and azure function is used to add the data to the queue of Azure service bus (ASB).<\/p>\n

\"Passing<\/p>\n

The detailed steps are as follows:-<\/h2>\n

1<\/strong>. Create an Azure Service Bus:-<\/p>\n

Open Azure portal in your CRM organization and Create Service Bus Namespace by navigating to + Create a Resource >> Integration >> Service Bus<\/p>\n

2<\/strong>. Create an Azure function which will add the CRM data to Azure Service Bus Queue:-<\/p>\n

a<\/strong>. Navigate to + Create a Resource >> Compute >> Function App<\/p>\n

b<\/strong>. Create a C# HttpTrigger Function in it<\/p>\n

c<\/strong>. Click on \u201cGet function URL\u201d link<\/p>\n

\"Passing<\/p>\n

\"Passing<\/p>\n

This URL link is important and will be used in CRM Plugin\/Workflow code and webhook registration.<\/p>\n

d<\/strong>. Click on Integrate and + New Output to create a queue in ASB and provide it to Azure function<\/p>\n

\"assing<\/p>\n

e<\/strong>. Select Azure Service Bus<\/p>\n

\"Passing<\/p>\n

f<\/strong>. Select \u201cService Bus Queue\u201d in Message Type. You can select the \u201cService Bus Connection\u201d by clicking on new and selecting the desired Service Bus.<\/p>\n

\"Passing<\/p>\n

g<\/strong>. Click on the function \u201cf<\/em> functionname\u201d and paste the following code to add the JSON data from CRM to the ASB Queue in the azure function. Save the code.<\/p>\n

using System;\r\nusing System.Net;\r\npublic static async Task<object> Run(HttpRequestMessage req,IAsyncCollector<Object> outputSbMsg, TraceWriter log)\r\n{\r\n    log.Info($\"Webhook was triggered!\");\r\n    string jsonContent = await req.Content.ReadAsStringAsync();\r\n    log.Info(\"jsonContent \" + jsonContent);\r\n    await outputSbMsg.AddAsync(jsonContent);\r\n    log.Info(\"added to queue\");    \r\n    return req.CreateResponse(HttpStatusCode.OK);\r\n}<\/pre>\n
Here,\u00a0\u00a0 \u00a0\u00a0HttpRequestMessage req is \u00a0JSON data from CRM<\/p>\n
IAsyncCollector<Object> outputSbMsg \u00a0is \u00a0ASB Queue name<\/p>\n
\"Passing<\/p>\n
3<\/strong>. Assume we are sending the data of Account entity to Azure Service Bus (ASB). The data should be in JSON format before it is passed to Azure portal. Below is the plugin\/workflow code:-<\/p>\n
\/\/ Create a Class having members as data attributes to be passed to Azure\r\n[DataContract]\r\npublic class AccountObj\r\n{\r\n[DataMember]\r\npublic string AccountID { get; set; }\r\n[DataMember]\r\npublic string Name { get; set; }\r\n[DataMember]\r\npublic string Telephone { get; set; }\r\n}\r\n\/\/ Insert the following code after getting the primary entity in Plugin\/workflow\r\nusing System.IO;\r\nusing System.Net;\r\nusing System.Runtime.Serialization.Json;\/\/Install from NuGet Package Manager\r\n\r\nusing (WebClient client = new WebClient())\r\n{\r\n\/\/ Prepare Json data                       \t\r\nDataContractJsonSerializer serializer = new DataContractJsonSerializer(typeof(AccountObj));\r\nMemoryStream memoryStream = new MemoryStream();\r\nserializer.WriteObject(memoryStream, accObj);\r\nvar jsonObject = Encoding.Default.GetString(memoryStream.ToArray());\r\n\r\n\/\/ Prepare WebHook\r\nvar webClient = new WebClient();\r\nwebClient.Headers[HttpRequestHeader.ContentType] = \"application\/json\";\r\n\r\n\/\/ Azure Function key\r\nvar code = \"xPhPPB5tGCq86NRbe7wzgJika3bv4ahP9kw7xe5Asoja2vEk4fPqVw==&clientId=default\";\r\n\/\/ Azure Function Url\r\nvar serviceUrl = \"https:\/\/callwebhookfromcrmassebly.azurewebsites.net\/api\/GenericWebhookCSharp1?code=\" + code;\r\n\r\n\/\/ upload the json data to the serviceurl \r\nstring response = webClient.UploadString(serviceUrl, jsonObject);\r\n  }\r\n<\/pre>\n
4<\/strong>. Webhook Registration:-<\/p>\n
With July 2017 Update, now we have the option to register a new Webhook through Plugin Registration tool. Download the latest Plugin Registration Tool from NuGet using the PowerShell script\u00a0\uf0e0<\/p>\n
https:\/\/docs.microsoft.com\/en-us\/dynamics365\/customer-engagement\/developer\/download-tools-nuget<\/a>.<\/p>\n
Through registering a Webhook, we can send data (execution context) about any operation performed on Dynamics 365 to the external services or application. The execution context information is passed in JSON format here.<\/p>\n
a<\/strong>. Open Plugin Registration tool and Register New WebHook<\/p>\n
\"Passing<\/p>\n
b<\/strong>. Enter details of registration from the \u201cGet function URL\u201d from step 2c<\/p>\n
\"Passing<\/p>\n
5<\/strong>. Register your plugin\/workflow assembly.<\/p>\n
Working: – In the example, when \u201cAccount Number\u201d of an account record is changed, the plugin\/workflow is triggered which executes the webhook. The webhook passes the data to azure function and the azure function adds the data to queue. The result can be seen as below in the azure function Monitor section.<\/p>\n
\"Passing<\/p>\n
\"Passing<\/p>\n
The CRM data is added as a message in the Queue of Azure service Bus as seen in the above screenshot.<\/p>\n
Conclusion:<\/strong><\/h2>\n
Using the simple steps above user can pass data from Dynamics 365 to Azure Service Bus Queue using Plugins\/Workflows.<\/p>\n
70% of global 2000 companies apply gamification to improve productivity and returns!<\/div><\/div><\/h2>\n
Gamifics365<\/a> <\/strong>\u2013 Spin the magic of games within Microsoft Dynamics 365 CRM to improve user adoption, enhance productivity, and achieve company goals!<\/em><\/p>\n","protected":false},"excerpt":{"rendered":"
Introduction: Recently we had a business requirement where we need to pass data from Dynamics 365 CRM to Azure Service Bus queue through plugins and workflows. After some research and play around we found a solution for this. For this, we require an Azure Service Bus, an Azure function and a webhook. The CRM data\u2026 Read More »<\/a><\/span><\/p>\n","protected":false},"author":13,"featured_media":12670,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"om_disable_all_campaigns":false,"_monsterinsights_skip_tracking":false,"_monsterinsights_sitenote_active":false,"_monsterinsights_sitenote_note":"","_monsterinsights_sitenote_category":0,"footnotes":""},"categories":[5,42,67],"tags":[190,1847],"class_list":["post-12658","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-azure-functions","category-plugin","category-workflows","tag-azure-service-bus-queue","tag-workflows-2"],"aioseo_notices":[],"_links":{"self":[{"href":"https:\/\/www.inogic.com\/blog\/wp-json\/wp\/v2\/posts\/12658","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.inogic.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.inogic.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.inogic.com\/blog\/wp-json\/wp\/v2\/users\/13"}],"replies":[{"embeddable":true,"href":"https:\/\/www.inogic.com\/blog\/wp-json\/wp\/v2\/comments?post=12658"}],"version-history":[{"count":0,"href":"https:\/\/www.inogic.com\/blog\/wp-json\/wp\/v2\/posts\/12658\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.inogic.com\/blog\/wp-json\/wp\/v2\/media\/12670"}],"wp:attachment":[{"href":"https:\/\/www.inogic.com\/blog\/wp-json\/wp\/v2\/media?parent=12658"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.inogic.com\/blog\/wp-json\/wp\/v2\/categories?post=12658"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.inogic.com\/blog\/wp-json\/wp\/v2\/tags?post=12658"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}