Write a incoming message into Azure Blob Storage Container using Mirth.4.5.0

The below code is to demonstrate how to write a incoming message in mirth to a azure blob storage container. Make sure you use all the libraries mentioned below
  • azure-core-1.48.0.jar
  • azure-core-http-netty-1.14.2.jar
  • azure-identity-1.12.0.jar
  • azure-json-1.1.0.jar
  • azure-storage-blob-12.25.3.jar
  • azure-storage-common-12.24.3.jar
  • azure-xml-1.0.0.jar
  • jackson-annotations-2.13.5.jar
  • jackson-core.2.13.5.jar
  • jackson-databind-2.13.5.jar
  • jackson-dataformat-xml-2.13.5.jar
  • jackson-datatype-jsr310-2.13.5.jar
  • netty-handler-4.1.101.Final.jar
  • netty-handler-proxy-4.1.101.Final.jar
  • netty-resolver-4.1.101.Final.jar
  • netty-resolver-dns-4.1.101.Final.jar

And note that if you miss to import any of these then it will not be working.

var connectionString = “DefaultEndpointsProtocol….”;
var uploadContainerName = $cfg(‘FOLDER_1’);
var deleteContainerName = $cfg(‘FOLDER_2’);
var failedContainerName = $cfg(‘FOLDER_3’);
var fileName = $s(‘fileName’);
var bufferValue =  1024;
var result;
try{
var containerClient = new com.azure.storage.blob.BlobServiceClientBuilder().connectionString(connectionString).buildClient().getBlobContainerClient(uploadContainerName);
var uploadBlobClient= containerClient.getBlobClient(fileName);
var inputStream= new  java.io.ByteArrayInputStream(connectorMessage.getRawData().getBytes());
uploadBlobClient.upload(inputStream);
}catch(Exception){
result = ‘There is an error in uploading the file to a container ‘+Exception.toString();
logger.debug(“Exception — “+Exception)
}
return result;

Leave a Comment