In this post, you will see a library that demonstrates doing Event Sourcing as a data persistence mechanism for Azure functions.
Introduction to Event Sourcing
At its very simplest, event sourcing is a way of storing state (for an entity) which works by storing the sequential history of all the events that have occurred to that entity. Changes to the entity are written as new events appended to the end of the event stream for the entity.
When a query or business process needs to use the current state of the entity, it gets this by running a projection over the event stream which is a very simple piece of code which, for each event, decides (a) do I care about this type of event and (b) if so, what do I do when I receive it.
There is a 50 minute talk that covers this on YouTube, or if you already have an understanding of event sourcing, you can go straight to the Getting started wiki page
How to Use
This library allows you to interact with the event streams for entities without any extra plumbing in the Azure function itself - with both access to event streams and to run projections being via bound variables that are instantiated when the Azure function is executed.
To add events to an event stream, you use an Event stream attribute and class thus:
[FunctionName("OpenAccount")]
public static async Task<HttpResponseMessage> OpenAccountRun(
[HttpTrigger(AuthorizationLevel.Function, "POST",
Route = "OpenAccount/{accountnumber}")]HttpRequestMessage req,
string accountnumber,
[EventStream("Bank", "Account", "{accountnumber}")]
EventStream bankAccountEvents)
{
if (await bankAccountEvents.Exists())
{
return req.CreateResponse(System.Net.HttpStatusCode.Forbidden ,
$"Account {accountnumber} already exists");
}
else
{
AccountOpeningData data = await req.Content.ReadAsAsync<AccountOpeningData>();
DateTime dateCreated = DateTime.UtcNow;
Account.Events.Opened evtOpened = new Account.Events.Opened()
{ LoggedOpeningDate = dateCreated };
if (! string.IsNullOrWhiteSpace( data.Commentary))
{
evtOpened.Commentary = data.Commentary;
}
await bankAccountEvents.AppendEvent(evtOpened);
return req.CreateResponse(System.Net.HttpStatusCode.Created ,
$"Account {accountnumber} created");
}
}
To get the values out of an event stream, you use a Projection attribute and class thus:
[FunctionName("GetBalance")]
public static async Task<HttpResponseMessage> GetBalanceRun(
[HttpTrigger(AuthorizationLevel.Function, "GET",
Route = "GetBalance/{accountnumber}")]HttpRequestMessage req,
string accountnumber,
[Projection("Bank", "Account", "{accountnumber}",
nameof(Balance))] Projection prjBankAccountBalance)
{
string result = $"No balance found for account {accountnumber}";
if (null != prjBankAccountBalance)
{
Balance projectedBalance = await prjBankAccountBalance.Process<Balance>();
if (null != projectedBalance )
{
result = $"Balance for account {accountnumber} is
${projectedBalance.CurrentBalance} (As at
{projectedBalance.CurrentSequenceNumber}) ";
}
}
return req.CreateResponse(System.Net.HttpStatusCode.OK, result);
}
All of the properties of these two attributes are set to AutoResolve so they can be set at run time.
Chosen Technologies
For production use and especially for higher volume streams, there is an Azure Tables back end that I recommend be used.
Alternatively, because an event stream is an inherently append only system, the storage technology underlying can be AppendBlob - a special type of Blob storage which only allows for blocks to be appended to the end of the blob. Each blob can store up to 50,000 events and the container path can be nested in the same way as any other Azure Blob storage.
The choice of storage technology and storage target is switchable by a configuration setting on the application, on a per domain/entity basis.
The Azure functions code is based on version 2.0 of the Azure functions SDK and is written in C#.
Comparison to Other Event Sourcing Implementations
In this library, the state of an entity has to be retrieved on demand - this is to allow for the functions application to be spun down to nothing and indeed for multiple independent Azure functions applications to use the same underlying event stream without having to have any "always on" consistency service.
Requirements
In order to use this library, you will need an Azure account with the ability to create a storage container and to host an Azure functions application.
If you want to use the notifications functionality, you will also need to set up an event grid topic that the library will push notifications to.
Roadmap
The current version allows the storing and projection of event stream backed entities in either Azure Tables storage (recommended) or AppendBlob. This includes the concurrency protection that is needed to do this safely in a many-writers, many-readers scenario.
It also has outgoing notificiations - effectively a change feed - that are raised whenever a new entity is created or when a new event is appended to the event stream of an existing entity. This is done via event grid to allow massive scale assembly of these event sourcing backed entities into an ecosystem.
The next phase is to have notification derived triggers which can listen to these outgoing notifications and trigger serverless functions when they occur, and to provide the scaffold for creating CQRS systems on Azure serverless.
