У меня есть функция Java Azure. Я хотел бы создать функцию, запускаемую служебной шиной, с выводом blob. Сообщение служебной шины имеет формат JSON. Я хотел бы добавлять содержимое в CSV по часам.
Я смотрю пример записи в большие двоичные объекты из здесь , но получаю сообщение об ошибке при импорте. Любой совет?
import com.microsoft.azure.storage.CloudStorageAccount; // cannot be resolved.
ОШИБКА:
package com.topictriggerdatalakeoutput;
import com.microsoft.azure.functions.annotation.*;
import com.microsoft.azure.functions.*;
import com.microsoft.azure.storage.CloudStorageAccount; // cannot be resolved.
/**
* Azure Functions with Service Topic Trigger.
*/
public class TopicTriggerDatalakeOutput {
/**
* This function will be invoked when a new message is received at the Service Bus Topic.
*/
@FunctionName("TopicTriggerDatalakeOutput")
public void run(
@ServiceBusTopicTrigger(
name = "message",
topicName = "MyTopic",
subscriptionName = "MyTopicDataLakeSubscription",
connection = "sbconnstring"
)
String message,
final ExecutionContext context
) {
String storageConnectionString = System.getenv("DataLakeconnstring");
CloudStorageAccount storageAccount; // cannot be resolved
//blobClient = storageAccount.createCloudBlobClient();
//container = blobClient.getContainerReference("quickstartcontainer");
}
}