Fiókkezelési műveletek Azure Data Lake Storage Gen1-en a Python használatával
Megtudhatja, hogyan használhatja a Python SDK for Azure Data Lake Storage Gen1-et olyan alapvető fiókkezelési műveletek végrehajtására, mint például egy Data Lake Storage Gen1 fiók létrehozása, a Data Lake Storage Gen1 fiókok listázása stb. A fájlrendszerműveletek pythonos Data Lake Storage Gen1 történő végrehajtásával kapcsolatos útmutatásért lásd: Fájlrendszerműveletek Data Lake Storage Gen1 a Python használatával.
Előfeltételek
Python. A Pythont innen töltheti le. Ez a cikk a Python 3.6.2-es verzióját használja.
Azure-előfizetés. Lásd: Ingyenes Azure-fiók létrehozása.
Egy Azure-erőforráscsoport. További útmutatásért lásd: Azure-erőforráscsoport létrehozása.
A modulok telepítése
A pythonos Data Lake Storage Gen1 használatához három modult kell telepítenie.
- Az
azure-mgmt-resource
modult, amely további Azure-modulokat tartalmaz az Active Directoryhoz és más eszközökhöz. - A
azure-mgmt-datalake-store
modul, amely magában foglalja a Azure Data Lake Storage Gen1 fiókkezelési műveleteket. A modullal kapcsolatos további információkért lásd: Azure Data Lake Storage Gen1 Management modul referenciája. - A
azure-datalake-store
modul, amely magában foglalja a Azure Data Lake Storage Gen1 fájlrendszerműveleteket. További információ erről a modulról: azure-datalake-store fájlrendszermodul-referencia.
A modulok telepítéséhez használja a következő parancsokat.
pip install azure-identity
pip install azure-mgmt-resource
pip install azure-mgmt-datalake-store
pip install azure-datalake-store
Új Python-alkalmazás létrehozása
A választott IDE-ben hozzon létre egy új Python-alkalmazást, például mysample.py néven.
Adja hozzá a következő kódrészletet a szükséges modulok importálásához:
# 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
Mentse a mysample.py módosításait.
Hitelesítés
Ebben a szakaszban a Microsoft Entra ID hitelesítésének különböző módjairól beszélünk. Az elérhető lehetőségek:
- Az alkalmazás végfelhasználói hitelesítésével kapcsolatban lásd: Végfelhasználói hitelesítés Data Lake Storage Gen1 a Python használatával.
- Az alkalmazás szolgáltatásközi hitelesítésével kapcsolatban lásd: Szolgáltatásközi hitelesítés Data Lake Storage Gen1 a Python használatával.
Ügyfél és Data Lake Storage Gen1 fiók létrehozása
A következő kódrészlet először létrehozza a Data Lake Storage Gen1 fiókügyfélt. Az ügyfélobjektum használatával hoz létre egy Data Lake Storage Gen1 fiókot. Végül pedig létrehoz egy fájlrendszerügyfél-objektumot.
## 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
)
)
A Data Lake Storage Gen1-fiókok listázása
## 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)
A Data Lake Storage Gen1 fiók törlése
## Delete an existing Data Lake Storage Gen1 account
adlsAcctClient.accounts.begin_delete(resourceGroup, adlsAccountName)