Azure IoTHub ExportDevicesAsync 引发内部服务器错误

Question

我正在研究一个解决方案，我想将所有设备从 IoTHub 导出到 BLOB。

Microsoft 对此有一个 API 并解释了如何做到这一点 here。

我已经为 10 台设备执行了这段代码，它工作正常，Azure 需要几秒钟来处理它，但除此之外它工作得很好。

但是我在 S1 平台上使用超过 10 台设备（目前正在测试 100 台设备），它应该支持数量不确定的设备

这是我用过的代码。

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);
    }
}

是我的代码出了问题，还是另有隐情？

Answer 1

原来我工作的服务器（西欧）出现了故障。我在北欧测试过，现在可以用了。

Azure IoTHub ExportDevicesAsync 引发内部服务器错误

Azure IoTHub ExportDevicesAsync throws internal server error

c#

azure

azure-iot-hub