After creating my solution and subsequent website project, I added a webjob using the built in mechanism to Visual Studio 2013, by right clicking on the web project, going to add, and selecting New Azure Webjob Project.
After running through a small wizard, a project is created for you with a 2 main code files.
class Program
{
static void Main(){
var host = new JobHost();
host.Call(typeof(Functions).GetMethod("ManualTrigger"),new {value = 20});
}
}
The other one is the functions file that contains a definition for ManualTrigger. The JobHost is part of the Azure WebJobs SDK and provides the following services out of the box:
- Get azure account strings from your app.config (the strings can also be passed in directly to the ctor).
- Reflect over your code to find C# methods with the SimpleBatch attributes. (much like how WebAPI discovers controllers)
- Listen for new blobs that match the [BlobInput] pattern.
- when a blob is found, invoke the function
- automatically log the invocation so that you can view the results in a separate dashboard.
One key thing to note is that I had to add two connection strings to my website config in order to get the dashboard to work correctly.
Another interesting thing is the way that the function is called. It's a static method that is called via reflection. Interesting. This makes it hard to do DI or anything like that. I guess the design pattern here is that a webjob should really do only one thing, and therefore, you shouldn't need to reuse a bunch of the code.
Okay moving on, since I was just fooling around and not following TDD, this is the first version of code that I wrote. Ewwwww. I didn't even want to show it.
There are several things bad about the above code, but most importantly, it isn't testable. I need this function to follow some logic:
- Read feed and get the latest info
- Read the database for all posts from that feed
- If the feed contains new posts, add them, else, continue on
Although it seems easy to read the above, I want to be able to make it testable. Furthermore, I don't like how this functions class knows about the database, etc. After some refactoring, here is what the code looks like.
[NoAutomaticTrigger]
public static void GetFeedData(TextWriter log, IDataService dataService, IRssService rssService)
{
var feeds = dataService.GetAllFeeds();
foreach (var feed in feeds)
{
Console.WriteLine("Processing " + feed.Name);
var posts = dataService.GetAllPostsFor(feed);
var newPosts = rssService.ReadRssFeed(feed);
var postsToAdd = newPosts.Where(x => !posts.Any(y => y.PostId.Equals(x.PostId))).ToList();
postsToAdd.ForEach(x => dataService.InsertPost(Post.CreateFrom(x, feed)));
}
}
After some refactoring and moving some core components out into services, I can now test the code. I used Moq in another test project (which I won't show here). One interesting thing about webjobs, is that any Console.Writeline messages actually get piped to the output and easily viewed.
Pretty cool. The last thing I needed to do is add in some error handling and event logging. It turns out that websites and webjobs use the built in Trace mechanism and log to a log source of your choice automatically. You can find out more about what those options are at this link
