1
IoTHubからBLOBにすべてのデバイスをエクスポートするソリューションを開発中です。Azure IoTHub ExportDevicesAsyncが内部サーバーエラーをスローする
マイクロソフトではAPIを使用しており、これを行う方法について説明していますhere。
私は10個のデバイスに対してこのコードを実行しましたが正常に動作しますが、Azureがこれを処理するには数秒かかりますが、それ以外はうまく動作します。
私はこれは私が使用したコードであるデバイス
の未定量をサポートする必要があり、10台の以上のデバイス(現在は100台のデバイスでテスト)S1プラットフォーム上で働いているが。
Program.csの
private static void Main(string[] args)
{
IoTExporter.ExportIoTDevices();
}
IoTExporter
public class IoTExporter
{
private const string Containername = "iot";
public static void ExportIoTDevices()
{
// Create a blobclient which is used to connect to the blob storage.
var blobClient = CreateBlobClient();
//Get a reference to a container to use for the sample code, and create it if it does not exist.
var container = blobClient.GetContainerReference(Containername);
container.CreateIfNotExists();
//Generate a SAS token and assign it to the current job.
var storageUri = GetContainerSasUri(container);
CreateJob(storageUri);
Console.ReadLine();
}
/// <summary>
/// Create a blobclient which is used to connect to the blob storage.
/// </summary>
/// <returns>A Blob client.</returns>
private static CloudBlobClient CreateBlobClient()
{
var storageAccount = CloudStorageAccount.Parse(CloudConfigurationManager.GetSetting("BlobConnString"));
return storageAccount.CreateCloudBlobClient();
}
private static string GetContainerSasUri(CloudBlobContainer container)
{
ConsoleWriter.WriteLine("Generating Uri");
// Set constraints on the SAS token.
var sasConstraints = new SharedAccessBlobPolicy
{
SharedAccessExpiryTime = DateTime.UtcNow.AddMinutes(10),
Permissions = SharedAccessBlobPermissions.Write | SharedAccessBlobPermissions.Read |
SharedAccessBlobPermissions.Delete
};
var sasContainerToken = container.GetSharedAccessSignature(sasConstraints);
//Return the URI string for the container, including the SAS token.
return container.Uri + sasContainerToken;
}
private static async void CreateJob(string storageUri)
{
ConsoleWriter.WriteLine("Creating Job");
var manager = RegistryManager.CreateFromConnectionString(ConfigurationManager.AppSettings["IoT:ConnectionString"]);
await TestConnection(manager);
ConsoleWriter.WriteLine("Initiating Job");
var job = await manager.ExportDevicesAsync(storageUri, "devices.txt", false);
await DoJob(job, manager);
}
private static async Task TestConnection(RegistryManager manager)
{
ConsoleWriter.WriteLine("Testing if connected to IoTHub");
var devices = await manager.GetDevicesAsync(1);
if (!devices.Any())
{
Environment.Exit(-1);
}
else
{
ConsoleWriter.WriteLine("IoT connected");
}
}
private static async Task DoJob(JobProperties job, RegistryManager manager)
{
while (true)
{
job = await manager.GetJobAsync(job.JobId);
switch (job.Status)
{
case JobStatus.Completed:
FileWriter.WriteBlobToFile(GetContainer());
ConsoleWriter.WriteLine($"Job {job.Status}");
break;
case JobStatus.Failed:
ConsoleWriter.WriteLine($"Job failed due to {job.FailureReason}");
break;
case JobStatus.Cancelled:
ConsoleWriter.WriteLine($"Job {job.Status}");
break;
default:
ConsoleWriter.WriteLine($"Status of job: {job.Status}");
await Task.Delay(TimeSpan.FromSeconds(5));
continue;
}
break;
}
}
private static CloudBlobContainer GetContainer()
{
var blobClient = CreateBlobClient();
// Retrieve a reference to a container and give it blob permissions.
var container = blobClient.GetContainerReference(Containername);
return container;
}}}
ConsoleWriter
public static class ConsoleWriter
{
public static void WriteLine(string line)
{
var date = DateTime.Now;
var toWrite = $"{date} : {line}";
Console.WriteLine(toWrite);
}
}
は私のコードproblですそれとも、鍋に何か醸造しているものがありますか?
私は、F1-Freeティアで100個のデバイスでコードをテストしています。詳細なエラー情報は何ですか? –
私が働いていたサーバー(西ヨーロッパ)に障害があることが判明しました。私は北ヨーロッパでそれをテストし、今は動作します! – Azgramah