Операции управления учетными записями в Azure Data Lake Storage 1-го поколения c использованием Python
Узнайте, как использовать Python SDK для Azure Data Lake Storage 1-го поколения для выполнения основных операций управления учетными записями, таких как создание учетной записи Data Lake Storage 1-го поколения, перечисление учетных записей Data Lake Storage 1-го поколения и т. д. Инструкции по выполнению операций с файловой системой в Data Lake Storage Gen1 с использованием Python, см. Операции с файловой системой в Data Lake Storage Gen1 с использованием Python.
Предварительные требования
Python. Скачать Python можно здесь. В этой статье используется версия Python 3.6.2.
Подписка Azure. См. страницу бесплатной пробной версии Azure.
Группа ресурсов Azure. Инструкции см. в статье Управление ресурсами Azure через портал.
Установка модулей
Для работы с Data Lake Storage 1-го поколения с использованием Python необходимо установить три модуля.
- Модуль
azure-mgmt-resource
, который включает в себя модули Azure для Active Directory и т. д. - Модуль
azure-mgmt-datalake-store
, который включает в себя операции по управлению учетной записью Azure Data Lake Storage 1-го поколения. Дополнительные сведения см. в справочнике по модулю управления Azure Data Lake Storage 1-го поколения. - Модуль
azure-datalake-store
, который включает в себя операции с файловой системой Azure Data Lake Storage 1-го поколения. Дополнительные сведения см. в справочнике по модулю файловой системы Azure Data Lake Store.
Чтобы установить модули, используйте следующие команды.
pip install azure-identity
pip install azure-mgmt-resource
pip install azure-mgmt-datalake-store
pip install azure-datalake-store
Создание приложения Python
Для создания приложения Python используйте IDE по своему усмотрению, например mysample.py.
Добавьте следующий фрагмент кода для импорта необходимых модулей:
# 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
Сохраните изменения в mysample.py.
Аутентификация
В этом разделе мы поговорим о различных способах проверки подлинности с помощью Microsoft Entra ID. Доступны следующие варианты.
- Дополнительные сведения о проверке подлинности пользователей в приложении см. в статье Аутентификация пользователей в Data Lake Store с помощью Python.
- Дополнительные сведения о проверке подлинности между службами в приложении см. в статье Аутентификация между службами в Data Lake Store с помощью Python.
Создание клиента и учетной записи Data Lake Storage 1-го поколения
Приведенный ниже фрагмент кода сначала создает клиент учетной записи Data Lake Storage 1-го поколения. Затем он использует объект клиента для создания учетной записи Data Lake Storage 1-го поколения. И наконец, он создает объект клиента файловой системы.
## 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 1-го поколения
## 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 1-го поколения
## Delete an existing Data Lake Storage Gen1 account
adlsAcctClient.accounts.begin_delete(resourceGroup, adlsAccountName)