다음을 통해 공유

.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를 사용하는 방법을 보여 주는 몇 가지 샘플입니다.

참고 항목

다음 단계