Be.Vlaanderen.Basisregisters.BlobStore 
Blob storage abstraction on top of AWS S3, Memory, Files and SQL Server. It's a bit leaky in that not all stores behave exactly in the same way and have different constraints towards names and metadata. Choose your blob names and metadata keys/values carefully - keep it simple. AWS S3 has no real concurrency mechanism and neither does Files.
Usage
// Memory
var memoryClient = new MemoryBlobClient();
// Files
var fileClient = new FileBlobClient(new DirectoryInfo("path-where-the-blobs-will-be-stored"));
// AWS S3
AmazonS3Client CreateClient()
{
return new AmazonS3Client(
new BasicAWSCredentials("your-access-key","your-secret"),
CreateClientConfig());
}
AmazonS3Config CreateClientConfig()
{
return new AmazonS3Config
{
LogMetrics = false,
DisableLogging = true,
DisableHostPrefixInjection = true,
ThrottleRetries = false,
UseHttp = true,
UseDualstackEndpoint = false,
UseAccelerateEndpoint = false,
EndpointDiscoveryEnabled = false,
ForcePathStyle = true,
ServiceURL = $"http://localhost:{_hostPort}"
};
}
var s3Client = new S3BlobClient(CreateClient(), "bucket-where-the-blobs-will-be-stored");
// SQL Server
var connectionStringBuilder = new SqlConnectionStringBuilder("connection-string-of-database-where-the-blobs-will-be-stored");
var sqlClient = new SqlBlobClient(connectionStringBuilder, "schema-within-said-database");The behavior you get across all of those is exposed via IBlobClient
public interface IBlobClient
{
// get a blob from storage including its name, metadata, content type and a way to open the content stream
Task<BlobObject> GetBlobAsync(BlobName name, CancellationToken cancellationToken = default);
// check if the blob is already in storage
Task<bool> BlobExistsAsync(BlobName name, CancellationToken cancellationToken = default);
// create a new blob in storage with name, metadata, content type and a content stream
Task CreateBlobAsync(BlobName name, Metadata metadata, ContentType contentType, Stream content, CancellationToken cancellationToken = default);
// delete a blob from storage
Task DeleteBlobAsync(BlobName name, CancellationToken cancellationToken = default);
}