共用方式為

使用 .NET SDK 對 Data Lake Storage Gen1 進行檔案系統作業

  • 發行項

在本文中，您會了解如何使用 .NET SDK 在 Data Lake Storage Gen1 上執行檔案系統作業。 檔案系統作業包括在 Data Lake Storage Gen1 帳戶中建立資料夾、上傳檔案、下載檔案等。

如需有關如何使用 .NET SDK 在 Data Lake Storage Gen1 上進行帳戶管理作業的指示，請參閱使用.NET SDK 在 Data Lake Storage Gen1 上進行帳戶管理作業。

必要條件

建立 .NET 應用程式

GitHub 上可用的程式碼範例會逐步引導您完成在存放區中建立檔案，串連檔案、下載檔案，以及刪除存放區中一些檔案的程序。 本節文章會逐步解說程式碼的主要部分。

  1. 在 Visual Studio 中，選取 [檔案] 功能表、[新增] 及 [專案]。

  2. 選擇 [主控台應用程式 (.NET Framework)]，然後選取 [下一步]。

  3. 在 [專案名稱] 中，輸入 CreateADLApplication，然後選取 [建立]。

  4. 將 NuGet 套件新增至您的專案。

    1. 在方案總管中以滑鼠右鍵按一下專案名稱，然後按一下 [ 管理 NuGet 封裝]。

    2. 在 [NuGet 套件管理員] 索引標籤中，確定 [套件來源] 設為 [nuget.org]，並確認已選取 [包含發行前版本] 核取方塊。

    3. 搜尋並安裝下列 NuGet 封裝：

      • Microsoft.Azure.DataLake.Store - 本文使用 v1.0.0。
      • Microsoft.Rest.ClientRuntime.Azure.Authentication - 本文使用 v2.3.1。

      關閉 [NuGet 套件管理員]。

  5. 開啟 Program.cs，刪除現有的程式碼，然後納入下列陳述式以新增命名空間的參考。

    using System;
using System.IO;using System.Threading;
using System.Linq;
using System.Text;
using System.Collections.Generic;
using System.Security.Cryptography.X509Certificates; // Required only if you're using an Azure AD application created with certificates

using Microsoft.Rest;
using Microsoft.Rest.Azure.Authentication;
using Microsoft.Azure.DataLake.Store;
using Microsoft.IdentityModel.Clients.ActiveDirectory;

  6. 宣告變數如下，並提供預留位置的值。 此外，請確定電腦上有此處提供的本機路徑和檔案名稱。

    namespace SdkSample
{
    class Program
    {
        private static string _adlsg1AccountName = "<DATA-LAKE-STORAGE-GEN1-NAME>.azuredatalakestore.net";
    }
}

在本文的其餘章節中，您可以了解如何使用可用的 .NET 方法來進行一些作業，例如驗證、檔案上載等。

驗證

建立用戶端物件

下列程式碼片段會建立 Data Lake Storage Gen1 檔案系統用戶端物件，以便對服務發出要求。

// Create client objects
AdlsClient client = AdlsClient.CreateClient(_adlsg1AccountName, adlCreds);

建立檔案和目錄

將下列程式碼片段新增至應用程式。 這個程式碼片段會新增檔案與任何不存在的父目錄。

// Create a file - automatically creates any parent directories that don't exist
// The AdlsOutputStream preserves record boundaries - it does not break records while writing to the store

using (var stream = client.CreateFile(fileName, IfExists.Overwrite))
{
    byte[] textByteArray = Encoding.UTF8.GetBytes("This is test data to write.\r\n");
    stream.Write(textByteArray, 0, textByteArray.Length);

    textByteArray = Encoding.UTF8.GetBytes("This is the second line.\r\n");
    stream.Write(textByteArray, 0, textByteArray.Length);
}

附加到檔案

下列程式碼片段會將資料附加至 Data Lake Storage Gen1 帳戶中的現有檔案。

// Append to existing file

using (var stream = client.GetAppendStream(fileName))
{
    byte[] textByteArray = Encoding.UTF8.GetBytes("This is the added line.\r\n");
    stream.Write(textByteArray, 0, textByteArray.Length);
}

讀取檔案

下列程式碼片段會讀取 Data Lake Storage Gen1 中的檔案內容。

//Read file contents

using (var readStream = new StreamReader(client.GetReadStream(fileName)))
{
    string line;
    while ((line = readStream.ReadLine()) != null)
    {
        Console.WriteLine(line);
    }
}

取得檔案屬性

下列程式碼片段會傳回與檔案或目錄相關聯的屬性。

// Get file properties
var directoryEntry = client.GetDirectoryEntry(fileName);
PrintDirectoryEntry(directoryEntry);

PrintDirectoryEntry 方法的定義包含在 Github 上的範例中。

重新命名檔案

下列程式碼片段會重新命名 Data Lake Storage Gen1 帳戶中的現有檔案。

// Rename a file
string destFilePath = "/Test/testRenameDest3.txt";
client.Rename(fileName, destFilePath, true);

列舉目錄

下列程式碼片段會列舉 Data Lake Storage Gen1 帳戶中的目錄。

// Enumerate directory
foreach (var entry in client.EnumerateDirectory("/Test"))
{
    PrintDirectoryEntry(entry);
}

PrintDirectoryEntry 方法的定義包含在 Github 上的範例中。

以遞迴方式刪除目錄

下列程式碼片段會以遞迴方式刪除目錄，以及其所有子目錄。

// Delete a directory and all its subdirectories and files
client.DeleteRecursive("/Test");

範例

以下是幾個可顯示如何使用 Data Lake Storage Gen1 Filesystem SDK 的範例。

另請參閱

下一步