Notes

using Microsoft.Azure.Cosmos;
using Microsoft.Azure.WebJobs;
using Microsoft.Extensions.Logging;
using System;
using System.IO;
using System.Text;
using System.Threading.Tasks;

public static class CosmosDbTrigger
{
[FunctionName("CosmosDbTriggerFunction")]
public static async Task Run(
[CosmosDBTrigger(
databaseName: "%DatabaseName%",
collectionName: "%ContainerName%",
ConnectionStringSetting = "CosmosDBConnectionString",
LeaseCollectionName = "leases",
CreateLeaseCollectionIfNotExists = true)]
IReadOnlyList<Document> documents,
ILogger log)
{
if (documents != null && documents.Count > 0)
{
foreach (var document in documents)
{
await ProcessDocument(document, log);
}
}
}

private static async Task ProcessDocument(Document document, ILogger log)
{
string documentId = document.Id;
DateTime timestamp = document.GetPropertyValue<DateTime>("_ts");
string jsonString = document.ToString();

// Enregistrer le document au format JSON dans ADLS Gen2
await SaveDocumentToADLS(documentId, timestamp, jsonString, log);

// Traiter le document reçu
log.LogInformation($"Document reçu : {jsonString}");
log.LogInformation($"Identifiant du document : {documentId}");
log.LogInformation($"Horodatage du document : {timestamp}");
}

private static async Task SaveDocumentToADLS(string documentId, DateTime timestamp, string jsonString, ILogger log)
{
// Configuration de l'accès à ADLS Gen2
string environment = Environment.GetEnvironmentVariable("Environment");
string adlsAccountName = Environment.GetEnvironmentVariable("ADLSAccountName");
string adlsKey = Environment.GetEnvironmentVariable("ADLSKey");
string dfsUri = "https://" + adlsAccountName + ".dfs.core.windows.net";
string fileSystemName = Environment.GetEnvironmentVariable("FileSystemName");

string year = timestamp.Year.ToString();
string month = timestamp.Month.ToString("D2");
string day = timestamp.Day.ToString("D2");

string directoryName = $"{environment}/bronze/CosmosDB/{year}/{month}/{day}";
string fileName = $"{documentId}_{timestamp:yyyyMMddHHmmss}.json";

log.LogInformation($"Nom du compte ADLS : {adlsAccountName}");
log.LogInformation($"Clé ADLS : {adlsKey}");
Azure.Storage.StorageSharedKeyCredential sharedKeyCredential = new Azure.Storage.StorageSharedKeyCredential(adlsAccountName, adlsKey);

DataLakeServiceClient dataLakeServiceClient = new DataLakeServiceClient(new Uri(dfsUri), sharedKeyCredential);

// Créer un client pour accéder à l'ADLS Gen2
DataLakeFileSystemClient fileSystemClient = dataLakeServiceClient.GetFileSystemClient(fileSystemName);

// Créer un répertoire s'il n'existe pas déjà
await fileSystemClient.CreateDirectoryAsync(directoryName);

// Créer ou écrire dans le fichier avec le contenu du document JSON
DataLakeFileClient fileClient = fileSystemClient.GetFileClient($"{directoryName}/{fileName}");
using (MemoryStream stream = new MemoryStream(Encoding.UTF8.GetBytes(jsonString)))
{
await fileClient.UploadAsync(stream, true);
}
}
}