你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

使用 Python 对 Azure Data Lake Storage Gen1 进行的帐户管理操作

了解如何使用 Python SDK for Azure Data Lake Storage Gen1 执行基本帐户管理操作(例如,创建 Data Lake Storage Gen1 帐户、列出 Data Lake Storage Gen1 帐户,等等)。有关如何使用 Python 对 Data Lake Storage Gen1 执行文件系统操作的说明,请参阅使用 Python 对 Data Lake Storage Gen1 执行的文件系统操作

先决条件

安装模块

若要通过 Python 使用 Data Lake Storage Gen1,需要安装三个模块。

使用以下命令安装这些模块。

pip install azure-identity
pip install azure-mgmt-resource
pip install azure-mgmt-datalake-store
pip install azure-datalake-store

创建新的 Python 应用程序

  1. 在所选的 IDE 中创建新的 Python 应用程序,例如,mysample.py

  2. 添加以下代码片段以导入所需的模块

     # Acquire a credential object for the app identity. When running in the cloud,
     # DefaultAzureCredential uses the app's managed identity (MSI) or user-assigned service principal.
     # When run locally, DefaultAzureCredential relies on environment variables named
     # AZURE_CLIENT_ID, AZURE_CLIENT_SECRET, and AZURE_TENANT_ID.
     from azure.identity import DefaultAzureCredential
    
     ## Required for Data Lake Storage Gen1 account management
     from azure.mgmt.datalake.store import DataLakeStoreAccountManagementClient
     from azure.mgmt.datalake.store.models import CreateDataLakeStoreAccountParameters
    
     ## Required for Data Lake Storage Gen1 filesystem management
     from azure.datalake.store import core, lib, multithread
    
     # Common Azure imports
     import adal
     from azure.mgmt.resource.resources import ResourceManagementClient
     from azure.mgmt.resource.resources.models import ResourceGroup
    
     # Use these as needed for your application
     import logging, getpass, pprint, uuid, time
    
  3. 将更改保存到 mysample.py。

身份验证

本部分介绍有关使用 Azure AD 进行身份验证的不同方式。 可用选项包括:

创建客户端和 Data Lake Storage Gen1 帐户

以下代码段首先创建 Data Lake Storage Gen1 帐户客户端。 它使用客户端对象来创建一个 Data Lake Storage Gen1 帐户。 最后,此代码段创建一个文件系统客户端对象。

## Declare variables
subscriptionId = 'FILL-IN-HERE'
adlsAccountName = 'FILL-IN-HERE'
resourceGroup = 'FILL-IN-HERE'
location = 'eastus2'
credential = DefaultAzureCredential()

## Create Data Lake Storage Gen1 account management client object
adlsAcctClient = DataLakeStoreAccountManagementClient(credential, subscription_id=subscriptionId)

## Create a Data Lake Storage Gen1 account
adlsAcctResult = adlsAcctClient.accounts.begin_create(
	resourceGroup,
	adlsAccountName,
	CreateDataLakeStoreAccountParameters(
		location=location
	)
)

列出 Data Lake Storage Gen1 帐户

## List the existing Data Lake Storage Gen1 accounts
result_list_response = adlsAcctClient.accounts.list()
result_list = list(result_list_response)
for items in result_list:
    print(items)

删除 Data Lake Storage Gen1 帐户

## Delete an existing Data Lake Storage Gen1 account
adlsAcctClient.accounts.begin_delete(resourceGroup, adlsAccountName)

后续步骤

另请参阅