다음을 통해 공유

.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의 계정 관리 작업을 참조하세요.

필수 조건

  • Visual Studio 2013 혹은 그 이상. 이 문서의 지침에서는 Visual Studio 2019를 사용합니다.

  • Azure 구독. Azure 평가판을 참조하세요.

  • Azure Data Lake Storage Gen1 계정. 계정을 만드는 방법에 대한 지침은 Azure 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를 사용하는 방법을 보여 주는 몇 가지 샘플은 다음과 같습니다.

참고하십시오

다음 단계