Azure DataLake 客户端无法创建目录

Question

我正在按照https://docs.microsoft.com/en-us/azure/storage/blobs/data-lake-storage-directory-file-acl-dotnet 中的步骤创建一个 POC 来在 Azure 中存储文件。在下面的 sn-p 中，创建目录失败并显示消息 No such host is known。 (securedfstest02.blob.core.windows.net:443)。感谢任何解决方法的建议 这个问题。

using Azure;
using Azure.Storage;
using Azure.Storage.Files.DataLake;
using Azure.Storage.Files.DataLake.Models;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;

namespace DataLakeHelloWorld
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("Hello World!");
            try
            {
                CreateFileClientAsync_DirectoryAsync().Wait();
            }
            catch(Exception e)
            {
                Console.WriteLine(e);
            }
        }

        static async Task CreateFileClientAsync_DirectoryAsync()
        {
            // Make StorageSharedKeyCredential to pass to the serviceClient
            string storageAccountName = "secureblobtest02";
            string storageAccountKey = "mykeyredacted";
            string dfsUri = "https://" + storageAccountName + ".dfs.core.windows.net";

            StorageSharedKeyCredential sharedKeyCredential = new StorageSharedKeyCredential(storageAccountName, storageAccountKey);

            // Create DataLakeServiceClient using StorageSharedKeyCredentials
            DataLakeServiceClient serviceClient = new DataLakeServiceClient(new Uri(dfsUri), sharedKeyCredential);

            // Create a DataLake Filesystem
            DataLakeFileSystemClient filesystem = serviceClient.GetFileSystemClient("my-filesystem");
            if(!await filesystem.ExistsAsync())
                await filesystem.CreateAsync();

            //Create a DataLake Directory
            DataLakeDirectoryClient directory = filesystem.CreateDirectory("my-dir");
            if (!await directory.ExistsAsync())
                await directory.CreateAsync();

            // Create a DataLake File using a DataLake Directory
            DataLakeFileClient file = directory.GetFileClient("my-file");
            if(!await file.ExistsAsync())
                await file.CreateAsync();

            // Verify we created one file
            var response = filesystem.GetPathsAsync();
            IAsyncEnumerator<PathItem> enumerator = response.GetAsyncEnumerator();
            Console.WriteLine(enumerator?.Current?.Name);

            // Cleanup
            await filesystem.DeleteAsync();
        }
    }
}

Answer 1

--更新

在您的问题中，您提到了 Azure 数据湖，但您似乎拥有主机：securedfstest02.blob.core.windows.net

Azure Data Lake Storage 使用 .dfs.core.windows.net/，而 Azure Blob Storage 使用 .blob.core.windows.net/ 在 ADLS 中使用与 Blob 服务相关的操作时，您也必须相应地更改端点。

请注意官方 MS 文档URI templates。

我使用了相同的代码并且能够创建目录。刚刚替换了我的 adls 凭据。我没有配置任何额外的权限。 ADLS 允许从所有网络访问。您可能需要检查您的默认配置是否为 specific 网络，或者防火墙是否允许客户端（您的）IP。

using Azure;
using Azure.Storage;
using Azure.Storage.Files.DataLake;
using Azure.Storage.Files.DataLake.Models;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;

namespace DataLakeHelloWorld
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("Starting....");
            try
            {
                Console.WriteLine("Executing...");
                CreateFileClientAsync_DirectoryAsync().Wait();
                Console.WriteLine("Done");
            }
            catch (Exception e)
            {
                Console.WriteLine(e);
            }
        }

        static async Task CreateFileClientAsync_DirectoryAsync()
        {
            // Make StorageSharedKeyCredential to pass to the serviceClient
            string storageAccountName = "kteststarageeadls";
            string storageAccountKey = "6fAe+P8LRe8LH0Ahxxxxxxxxx5ma17Slr7SjLy4oVYSgj05m+zWZuy5X8p4/Bbxxx8efzCj/X+On/Fwmxxxo7g==";
            string dfsUri = "https://" + "kteststarageeadls" + ".dfs.core.windows.net";

            StorageSharedKeyCredential sharedKeyCredential = new StorageSharedKeyCredential(storageAccountName, storageAccountKey);

            // Create DataLakeServiceClient using StorageSharedKeyCredentials
            DataLakeServiceClient serviceClient = new DataLakeServiceClient(new Uri(dfsUri), sharedKeyCredential);

            // Create a DataLake Filesystem
            DataLakeFileSystemClient filesystem = serviceClient.GetFileSystemClient("my-filesystem");
            if (!await filesystem.ExistsAsync())
                await filesystem.CreateAsync();

            //Create a DataLake Directory
            DataLakeDirectoryClient directory = filesystem.CreateDirectory("my-dir");
            if (!await directory.ExistsAsync())
                await directory.CreateAsync();

            // Create a DataLake File using a DataLake Directory
            DataLakeFileClient file = directory.GetFileClient("my-file");
            if (!await file.ExistsAsync())
                await file.CreateAsync();

            // Verify we created one file
            var response = filesystem.GetPathsAsync();
            IAsyncEnumerator<PathItem> enumerator = response.GetAsyncEnumerator();
            Console.WriteLine(enumerator?.Current?.Name);

            // Cleanup
            //await filesystem.DeleteAsync();
        }
    }
}

我修改了存储账户密钥，仅供参考。