共用方式為

使用 .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 文件系統 SDK 的範例。

另請參閱

後續步驟