{"id":214,"date":"2014-09-12T19:26:47","date_gmt":"2014-09-12T19:26:47","guid":{"rendered":"https:\/\/blogs.msdn.microsoft.com\/webdev\/2014\/09\/12\/announcing-the-0-6-0-beta-preview-of-microsoft-azure-webjobs-sdk\/"},"modified":"2022-08-08T04:01:04","modified_gmt":"2022-08-08T11:01:04","slug":"announcing-the-0-6-0-beta-preview-of-microsoft-azure-webjobs-sdk","status":"publish","type":"post","link":"https:\/\/devblogs.microsoft.com\/dotnet\/announcing-the-0-6-0-beta-preview-of-microsoft-azure-webjobs-sdk\/","title":{"rendered":"Announcing the 0.6.0-beta preview of Microsoft Azure WebJobs SDK"},"content":{"rendered":"

We are releasing another preview of the Microsoft Azure WebJobs SDK, which was introduced by Scott Hanselman<\/a>. To read more about the previous preview, read this announcement post<\/a>.<\/p>\n

This release has the same general feature set as 0.5.0-beta as well as a few new exciting ones.<\/p>\n

Download this release<\/strong><\/h2>\n

You can download the WebJobs SDK from the NuGet gallery. You can install or update these packages from the NuGet gallery using the NuGet Package Manager Console, like this:<\/p>\n

Install-Package Microsoft.Azure.WebJobs \u2013Pre<\/pre>\n
If you want to use Microsoft Azure Service Bus triggers, install the following package: \n  <\/p>\n
Install-Package Microsoft.Azure.WebJobs.ServiceBus -Pre<\/pre>\n
<\/h4>\n
What is the WebJobs SDK?<\/strong><\/h2>\n
The WebJobs<\/a> feature of Microsoft Azure Web Sites provides an easy way for you to run programs such as services or background tasks in a Web Site. You can upload and run an executable file such as an .exe<\/i>, .cmd<\/i>, or .bat<\/i> file to your web site while running these as triggered or continuous WebJobs. Without the WebJobs SDK, connecting and running background task requires a lot of complex programming. The SDK provides a framework that lets you write a minimum amount of code to get common tasks done.<\/p>\n
The WebJobs SDK<\/strong> has a binding and trigger system which works with Microsoft Azure Storage Blobs, Queues and Tables as well as Service Bus. The binding system makes it easy to write code that reads or writes Microsoft Azure Storage objects. The trigger system calls a function in your code whenever any new data is received in a queue or blob.<\/p>\n
Updates in this preview<\/strong><\/h2>\n
Table Ingress.<\/strong><\/h3>\n
One of the offerings in the SDK is to bind to Azure Storage Tables. In this release the SDK allows you to Ingress data into Azure Tables. Ingress is a common scenario when you are parsing files stored in blobs and storing the values in Tables such as CSV readers. In these cases the Ingress function could be writing lots of rows (million in some cases<\/em>).<\/p>\n
The WebJobs SDK makes it possible to implement this functionality easily and allows add real time monitoring capabilities such as number of rows written in the table so you can monitor the progress of the Ingress function.<\/p>\n
The following function show how you can write 100,000 rows into Azure Table storage.<\/p>\n
<\/strong><\/p>\n
\n
\n
Code Snippet<\/div>\n
\n
    \n
  1. <\/span>public<\/span> <\/span>static<\/span> <\/span>class<\/span> <\/span>Program<\/span><\/li>\n
  2. {<\/span><\/li>\n
  3. \u00a0\u00a0\u00a0\u00a0<\/span>static<\/span> <\/span>void<\/span> Main()<\/span><\/li>\n
  4. \u00a0\u00a0\u00a0\u00a0{<\/span><\/li>\n
  5. \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/span>JobHost<\/span> host = <\/span>new<\/span> <\/span>JobHost<\/span>();<\/span><\/li>\n
  6. \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0host.Call(<\/span>typeof<\/span>(<\/span>Program<\/span>).GetMethod(<\/span>"Ingress"<\/span>));<\/span><\/li>\n
  7. \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}<\/span><\/li>\n
  8. \u00a0\u00a0\u00a0\u00a0[<\/span>NoAutomaticTrigger<\/span>]<\/span><\/li>\n
  9. \u00a0\u00a0\u00a0\u00a0<\/span>public<\/span> <\/span>static<\/span> <\/span>void<\/span> Ingress([<\/span>Table<\/span>(<\/span>"Ingress"<\/span>)] <\/span>ICollector<\/span><<\/span>Person<\/span>> tableBinding)<\/span><\/li>\n
  10. \u00a0\u00a0\u00a0\u00a0{<\/span><\/li>\n
  11. \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/span>\/\/ Loop to simulate Ingressing lots of rows. <\/span><\/li>\n
  12. \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/span>\/\/ You would replace this with your own logic<\/span><\/li>\n
  13. \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/span>\/\/ of reading from blob storage and write to Azure Tables.<\/span><\/li>\n
  14. \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/span>for<\/span> (<\/span>int<\/span> i = 0; i < 100000; i++)<\/span><\/li>\n
  15. \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0{<\/span><\/li>\n
  16. \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0tableBinding.Add(<\/span><\/li>\n
  17. \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0<\/span>new<\/span> <\/span>Person<\/span>() <\/span><\/li>\n
  18. \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0{ PartitionKey = <\/span>"Foo"<\/span>, RowKey = i.ToString(), Name = <\/span>"Name"<\/span> }<\/span><\/li>\n
  19. \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0);<\/span><\/li>\n
  20. \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}<\/span><\/li>\n
  21. \u00a0\u00a0\u00a0\u00a0}<\/span><\/li>\n
  22. }<\/span><\/li>\n
  23. <\/span>public<\/span> <\/span>class<\/span> <\/span>Person<\/span><\/li>\n
  24. {<\/span><\/li>\n
  25. \u00a0\u00a0\u00a0\u00a0<\/span>public<\/span> <\/span>string<\/span> PartitionKey { <\/span>get<\/span>; <\/span>set<\/span>; }<\/span><\/li>\n
  26. \u00a0\u00a0\u00a0\u00a0<\/span>public<\/span> <\/span>string<\/span> RowKey { <\/span>get<\/span>; <\/span>set<\/span>; }<\/span><\/li>\n
  27. \u00a0\u00a0\u00a0\u00a0<\/span>public<\/span> <\/span>string<\/span> Name { <\/span>get<\/span>; <\/span>set<\/span>; }<\/span><\/li>\n
  28. }<\/span><\/li>\n<\/ol>\n<\/div>\n<\/div>\n<\/div>\n
    When you run this function and view the function in the dashboard, you will the following snapshot. The dashboard will show in real time how many rows are written in the table called \u201cIngress\u201d. Since this is a long running function the dashboard shows an \u201cAbort Host\u201d button which allows you to cancel a long running function.<\/p>\n
    \"IngressInProcess\"<\/a> <\/p>\n
    When the Ingress function completes successfully, then the dashboard displays a success message as shown below.<\/p>\n
    \"IngressComplete\"<\/a> <\/p>\n
    In the above example, the Ingress function was invoked through host.Call(). You can use this pattern to call this Ingress program on a schedule. You can also call the Ingress function when a new blob is uploaded in a container. For eg. if you have a background processing program which parses files stored in blob storage and writes the data into tables then you can do something like below:<\/p>\n
    \n
    \n
    Code Snippet<\/div>\n
    \n
      \n
    1. public<\/span> <\/span>static<\/span> <\/span>class<\/span> <\/span>Program<\/span><\/li>\n
    2. {<\/span><\/li>\n
    3. static<\/span> <\/span>void<\/span> Main()<\/span><\/li>\n
    4. {<\/span><\/li>\n
    5. \u00a0\u00a0\u00a0\u00a0<\/span>JobHost<\/span> host = <\/span>new<\/span> <\/span>JobHost<\/span>();<\/span><\/li>\n
    6. \u00a0\u00a0\u00a0\u00a0host.RunAndBlock();<\/span><\/li>\n
    7. }<\/span><\/li>\n
    8. public<\/span> <\/span>static<\/span> <\/span>void<\/span> CSVParsing(<\/span><\/li>\n
    9. [<\/span>BlobTrigger<\/span>(<\/span>@"table-uploads\{name}"<\/span>)] <\/span>TextReader<\/span> input,<\/span><\/li>\n
    10. [<\/span>Table<\/span>(<\/span>"Ingress"<\/span>)] <\/span>ICollector<\/span><<\/span>Person<\/span>> tableBinding)<\/span><\/li>\n
    11. {<\/span><\/li>\n
    12. \u00a0\u00a0\u00a0\u00a0<\/span>\/\/ This is psuedo code showing how you can parse your CSV files<\/span><\/li>\n
    13. \u00a0\u00a0\u00a0\u00a0<\/span>\/\/ and store them into Azure Tables<\/span><\/li>\n
    14. \u00a0\u00a0\u00a0\u00a0<\/span>IEnumerable<\/span><<\/span>Person<\/span>> rows = ParseUsingMyCSVParser<<\/span>Person<\/span>>(inputStream);<\/span><\/li>\n
    15. \u00a0\u00a0\u00a0\u00a0<\/span>foreach<\/span> (<\/span>var<\/span> row <\/span>in<\/span> rows)<\/span><\/li>\n
    16. \u00a0\u00a0\u00a0\u00a0{<\/span><\/li>\n
    17. \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0tableBinding.Add(row);<\/span><\/li>\n
    18. \u00a0\u00a0\u00a0\u00a0}<\/span><\/li>\n
    19. }<\/span><\/li>\n
    20. }<\/span><\/li>\n
    21. public<\/span> <\/span>class<\/span> <\/span>Person<\/span><\/li>\n
    22. {<\/span><\/li>\n
    23. \u00a0\u00a0\u00a0\u00a0<\/span>public<\/span> <\/span>string<\/span> PartitionKey { <\/span>get<\/span>; <\/span>set<\/span>; }<\/span><\/li>\n
    24. \u00a0\u00a0\u00a0\u00a0<\/span>public<\/span> <\/span>string<\/span> RowKey { <\/span>get<\/span>; <\/span>set<\/span>; }<\/span><\/li>\n
    25. \u00a0\u00a0\u00a0\u00a0<\/span>public<\/span> <\/span>string<\/span> Name { <\/span>get<\/span>; <\/span>set<\/span>; }<\/span><\/li>\n
    26. }<\/span><\/li>\n<\/ol>\n<\/div>\n<\/div>\n<\/div>\n
      As a developer now you implement Ingress scenarios fairly easily and also get real time monitoring on the dashboard without having to write any diagnostics code yourself.<\/p>\n
      Apart from Ingress scenarios, you can also do the following with Azure Tables:<\/p>\n