Skip to main content

Azure Data Lake and Replication mechanism cross Azure Regions

Let’s imagine that we are working in an automotive company that collects telemetric data from their cars. A part of this data needs to be processed, stored and managed.
To be able to store data now and use it later on in time, you decided to go with Azure Data Lake, that is not limited on how much data you can store and allows you to plug any kind of processing system.
After the architecture audit, because of legal constraints you are required to have a resiliency policy for disaster recovery. Even if in the same Azure Region there are 3 copies of data that are generated by Azure Data Lake, the legal constraints require you to have a resiliency policy.
Azure Data Lake makes 3 copies of data in the same Azure Region, but there is no support to replicated or backup content in a different Azure Region. You will need to define you own mechanism for this.

Available Solutions
We could fine many ways of doing this. There are 2-3 mechanism to do replication of Azure Data Lake cross region that is cost efficient and also not too complex from implementation point of view.
Azure Data Factory
One of the basic features of Azure Data Factory is support for copy activities. This is a generic service that allows us to move data from different types of storages. From binary content point of view, the current copy activities supported by Azure Data Factory offers us speeds up to 1 GBps for Azure Blob Storage and Azure Data Lake.
This command can be used to move data from one Azure Data Lake to another. The command can be used with success as long as we integrate it in Azure Automation. This is required, because the command cannot run by its own. Azure Automation is the shell from where we run the command.

Downside of this solutions
This solution works well for small amount of data and when we don’t care about the deltas. If we can identify deltas by our self or we don’t care about it and we want to replicate everything than the previous two solutions are perfect.
If the process of delta identifications is too complex that we should go with Distcp command

This can be used in combination with HDInsight to copy content from one storage to another. In comparison with the previous ones, it enables us to copy only the delta. Beside this, this command runs on top of a HDInsight (Hadoop) cluster, allowing it to scale inside the cluster based on how much traffic needs to be moved.

What’s suite our need?
Telemetric data collected from cars are grouped together per car and day and never updated. This means that we can identify easily what files need to be moved. Each car has a virtual folder with his own telemetric data. A new file is created each day. When a new car is sold, a new virtual folder is created.

This allows us to identify easily what files needs to be replicated and we don’t need to care about deltas, because we run the replication job only one time per day.
Taking this into account, Azure Data Factory is a good candidate.

As can see, there are multiple ways to do replication between different instances of Azure Data Factory. Even if Distcp is the best one, you need to take into account that you need to spin HDInsight clusters, that are more expensive that AdlCopy or Azure Data Factory.
When you handle storages where content is updated or copies rarely, then a solution based on Distcp might be too expensive and complex.


Popular posts from this blog

ADO.NET provider with invariant name 'System.Data.SqlClient' could not be loaded

Today blog post will be started with the following error when running DB tests on the CI machine:
threw exception: System.InvalidOperationException: The Entity Framework provider type 'System.Data.Entity.SqlServer.SqlProviderServices, EntityFramework.SqlServer' registered in the application config file for the ADO.NET provider with invariant name 'System.Data.SqlClient' could not be loaded. Make sure that the assembly-qualified name is used and that the assembly is available to the running application. See for more information. at System.Data.Entity.Infrastructure.DependencyResolution.ProviderServicesFactory.GetInstance(String providerTypeName, String providerInvariantName) This error happened only on the Continuous Integration machine. On the devs machines, everything has fine. The classic problem – on my machine it’s working. The CI has the following configuration:

TeamCity.NET 4.51EF 6.0.2VS2013
It seems that there …

Fundamental Books of a Software Engineer (version 2018)

More then six years ago I wrote a blog post about fundamental books that any software engineer (developer) should read. Now it is an excellent time to update this list with new entries.

There are 5 different categories of books, that represent the recommended path. For example, you start with Coding books, after that, you read books about Programming, Design and so on.
There are some books about C++ that I recommend not because you shall know C++, only because the concepts that you can learn from it.


Writing solid codeCode completeProgramming Pearls, more programming pearls(recommended)[NEW] Introduction to Algorithms


Refactoring (M. Fowler)Pragmatic ProgrammerClean code[NEW] Software Engineering: A Practitioner's Approach[NEW] The Mythical Man-Month[NEW] The Art of Computer Programming


Applying UML and Patterns (GRASP patterns)C++ coding standards (Sutter, Alexandrescu)The C++ programming language (Stroustrup, Part IV)Object-oriented programming (Peter Coad)P…

How to check in AngularJS if a service was register or not

There are cases when you need to check in a service or a controller was register in AngularJS.
For example a valid use case is when you have the same implementation running on multiple application. In this case, you may want to intercept the HTTP provider and add a custom step there. This step don’t needs to run on all the application, only in the one where the service exist and register.
A solution for this case would be to have a flag in the configuration that specify this. In the core you would have an IF that would check the value of this flag.
Another solution is to check if a specific service was register in AngularJS or not. If the service was register that you would execute your own logic.
To check if a service was register or not in AngularJS container you need to call the ‘has’ method of ‘inhector’. It will return TRUE if the service was register.
if ($injector.has('httpInterceptorService')) { $httpProvider.interceptors.push('httpInterceptorService&#…