DataLakeServiceClient class
DataLakeServiceClient consente di modificare le risorse e i file system del servizio Azure Data Lake. L'account di archiviazione fornisce lo spazio dei nomi di primo livello per il servizio Data Lake.
- Extends
-
StorageClient
Costruttori
Data |
Crea un'istanza di DataLakeServiceClient dall'URL e dalla pipeline. |
Data |
Crea un'istanza di DataLakeServiceClient dall'URL. |
Proprietà ereditate
account |
|
credential | Ad esempio AnonymousCredential, StorageSharedKeyCredential o qualsiasi credenziale del |
url | Valore stringa URL codificato. |
Metodi
from |
Crea un'istanza di DataLakeServiceClient dalla stringa di connessione. |
generate |
Disponibile solo per DataLakeServiceClient costruito con le credenziali delle chiavi condivise. Genera un URI firma di accesso condiviso dell'account in base alle proprietà e ai parametri client passati. La firma di accesso condiviso viene firmata dalla credenziale della chiave condivisa del client. Vedere https://docs.microsoft.com/en-us/rest/api/storageservices/create-account-sas |
get |
Crea un oggetto DataLakeFileSystemClient . |
get |
Ottiene le proprietà dell'endpoint del servizio BLOB di un account di archiviazione, incluse le proprietà per le regole di Analisi archiviazione e CORS (Condivisione risorse tra le origini). Vedere https://docs.microsoft.com/en-us/rest/api/storageservices/get-blob-service-properties |
get |
DISPONIBILE SOLO QUANDO SI USA L'AUTENTICAZIONE DEL TOKEN DI CONNESSIONE (TokenCredential). Recupera una chiave di delega utente per il servizio Data Lake. Si tratta di un'operazione valida solo quando si usa l'autenticazione del token di connessione. Esempio
Vedere https://docs.microsoft.com/en-us/rest/api/storageservices/get-user-delegation-key |
list |
Restituisce un iteratore iteratore iterabile asincrono per elencare tutti i file system nell'account specificato. .byPage() restituisce un iteratore iteratore iterabile asincrono per elencare i file system nelle pagine. Esempio di uso
Esempio con
Esempio con
Esempio di uso del paging con un marcatore:
Vedere https://docs.microsoft.com/en-us/rest/api/storageservices/list-containers2 |
set |
Imposta le proprietà per l'endpoint del servizio BLOB di un account di archiviazione, incluse le proprietà per Analisi archiviazione, le regole CORS (Condivisione risorse tra le origini) e le impostazioni di eliminazione temporanea. Vedere https://docs.microsoft.com/en-us/rest/api/storageservices/set-blob-service-properties |
undelete |
Ripristinare un file system eliminato in precedenza. Questa API è funzionante solo se l'eliminazione temporanea del contenitore è abilitata per l'account di archiviazione. |
Dettagli costruttore
DataLakeServiceClient(string, Pipeline)
Crea un'istanza di DataLakeServiceClient dall'URL e dalla pipeline.
new DataLakeServiceClient(url: string, pipeline: Pipeline)
Parametri
- url
-
string
Stringa client che punta al servizio Data Lake di Archiviazione di Azure, ad esempio "https://myaccount.dfs.core.windows.net". È possibile aggiungere una firma di accesso condiviso se si usa AnonymousCredential, ad esempio "https://myaccount.dfs.core.windows.net?sasString".
- pipeline
- Pipeline
Chiamare newPipeline() per creare una pipeline predefinita o fornire una pipeline personalizzata.
DataLakeServiceClient(string, StorageSharedKeyCredential | AnonymousCredential | TokenCredential, StoragePipelineOptions)
Crea un'istanza di DataLakeServiceClient dall'URL.
new DataLakeServiceClient(url: string, credential?: StorageSharedKeyCredential | AnonymousCredential | TokenCredential, options?: StoragePipelineOptions)
Parametri
- url
-
string
Stringa client che punta al servizio Data Lake di Archiviazione di Azure, ad esempio "https://myaccount.dfs.core.windows.net". È possibile aggiungere una firma di accesso condiviso se si usa AnonymousCredential, ad esempio "https://myaccount.dfs.core.windows.net?sasString".
- credential
-
StorageSharedKeyCredential | AnonymousCredential | TokenCredential
Ad esempio AnonymousCredential, StorageSharedKeyCredential o qualsiasi credenziale del @azure/identity
pacchetto per autenticare le richieste al servizio. È anche possibile fornire un oggetto che implementa l'interfaccia TokenCredential. Se non specificato, viene usata AnonymousCredential.
- options
- StoragePipelineOptions
Facoltativa. Opzioni per configurare la pipeline HTTP.
Dettagli proprietà ereditate
accountName
accountName: string
Valore della proprietà
string
Ereditato da StorageClient.accountName
credential
Ad esempio AnonymousCredential, StorageSharedKeyCredential o qualsiasi credenziale del @azure/identity
pacchetto per autenticare le richieste al servizio. È anche possibile fornire un oggetto che implementa l'interfaccia TokenCredential. Se non specificato, viene usata AnonymousCredential.
credential: StorageSharedKeyCredential | AnonymousCredential | TokenCredential
Valore della proprietà
Ereditato da StorageClient.credential
url
Valore stringa URL codificato.
url: string
Valore della proprietà
string
Ereditato da StorageClient.url
Dettagli metodo
fromConnectionString(string, StoragePipelineOptions)
Crea un'istanza di DataLakeServiceClient dalla stringa di connessione.
static function fromConnectionString(connectionString: string, options?: StoragePipelineOptions): DataLakeServiceClient
Parametri
- connectionString
-
string
Stringa di connessione dell'account o stringa di connessione SAS di un account di archiviazione di Azure.
[ Nota : la stringa di connessione dell'account può essere usata solo nel runtime di NODE.JS. ] Esempio di stringa di connessione account -DefaultEndpointsProtocol=https;AccountName=myaccount;AccountKey=accountKey;EndpointSuffix=core.windows.net
Esempio di stringa di connessione SAS - BlobEndpoint=https://myaccount.blob.core.windows.net/;QueueEndpoint=https://myaccount.queue.core.windows.net/;FileEndpoint=https://myaccount.file.core.windows.net/;TableEndpoint=https://myaccount.table.core.windows.net/;SharedAccessSignature=sasString
- options
- StoragePipelineOptions
Facoltativa. Opzioni per configurare la pipeline HTTP.
Restituisce
generateAccountSasUrl(Date, AccountSASPermissions, string, ServiceGenerateAccountSasUrlOptions)
Disponibile solo per DataLakeServiceClient costruito con le credenziali delle chiavi condivise.
Genera un URI firma di accesso condiviso dell'account in base alle proprietà e ai parametri client passati. La firma di accesso condiviso viene firmata dalla credenziale della chiave condivisa del client.
Vedere https://docs.microsoft.com/en-us/rest/api/storageservices/create-account-sas
function generateAccountSasUrl(expiresOn?: Date, permissions?: AccountSASPermissions, resourceTypes?: string, options?: ServiceGenerateAccountSasUrlOptions): string
Parametri
- expiresOn
-
Date
Facoltativa. Ora in cui la firma di accesso condiviso non è valida. Impostazione predefinita su un'ora successiva se non specificata.
- permissions
- AccountSASPermissions
Specifica l'elenco delle autorizzazioni da associare alla firma di accesso condiviso.
- resourceTypes
-
string
Specifica i tipi di risorse associati alla firma di accesso condiviso.
Parametri facoltativi.
Restituisce
string
URI di firma di accesso condiviso dell'account costituito dall'URI della risorsa rappresentata da questo client, seguito dal token di firma di accesso condiviso generato.
getFileSystemClient(string)
Crea un oggetto DataLakeFileSystemClient .
function getFileSystemClient(fileSystemName: string): DataLakeFileSystemClient
Parametri
- fileSystemName
-
string
Nome del file system.
Restituisce
getProperties(ServiceGetPropertiesOptions)
Ottiene le proprietà dell'endpoint del servizio BLOB di un account di archiviazione, incluse le proprietà per le regole di Analisi archiviazione e CORS (Condivisione risorse tra le origini).
Vedere https://docs.microsoft.com/en-us/rest/api/storageservices/get-blob-service-properties
function getProperties(options?: ServiceGetPropertiesOptions): Promise<ServiceGetPropertiesResponse>
Parametri
- options
- ServiceGetPropertiesOptions
Opzioni per l'operazione Service Get Properties.Options to the Service Get Properties operation.
Restituisce
Promise<DataLakeServiceGetPropertiesResponse>
Dati di risposta per l'operazione Service Get Properties.
getUserDelegationKey(Date, Date, ServiceGetUserDelegationKeyOptions)
DISPONIBILE SOLO QUANDO SI USA L'AUTENTICAZIONE DEL TOKEN DI CONNESSIONE (TokenCredential).
Recupera una chiave di delega utente per il servizio Data Lake. Si tratta di un'operazione valida solo quando si usa l'autenticazione del token di connessione.
Esempio
// Generate user delegation SAS for a file system
const userDelegationKey = await dataLakeServiceClient.getUserDelegationKey(startsOn, expiresOn);
const fileSystemSAS = generateDataLakeSASQueryParameters({
fileSystemName, // Required
permissions: FileSystemSASPermissions.parse("racwdl"), // Required
startsOn, // Required. Date type
expiresOn, // Optional. Date type
ipRange: { start: "0.0.0.0", end: "255.255.255.255" }, // Optional
protocol: SASProtocol.HttpsAndHttp, // Optional
version: "2018-11-09" // Must greater than or equal to 2018-11-09 to generate user delegation SAS
},
userDelegationKey, // UserDelegationKey
accountName
).toString();
Vedere https://docs.microsoft.com/en-us/rest/api/storageservices/get-user-delegation-key
function getUserDelegationKey(startsOn: Date, expiresOn: Date, options?: ServiceGetUserDelegationKeyOptions): Promise<ServiceGetUserDelegationKeyResponse>
Parametri
- startsOn
-
Date
Ora di inizio per la firma di accesso condiviso della delega utente. Deve essere entro 7 giorni dall'ora corrente.
- expiresOn
-
Date
Ora di fine per la firma di accesso condiviso della delega utente. Deve essere entro 7 giorni dall'ora corrente.
Restituisce
Promise<ServiceGetUserDelegationKeyResponse>
listFileSystems(ServiceListFileSystemsOptions)
Restituisce un iteratore iteratore iterabile asincrono per elencare tutti i file system nell'account specificato.
.byPage() restituisce un iteratore iteratore iterabile asincrono per elencare i file system nelle pagine.
Esempio di uso for await
della sintassi:
let i = 1;
for await (const fileSystem of serviceClient.listFileSystems()) {
console.log(`FileSystem ${i++}: ${fileSystem.name}`);
}
Esempio con iter.next()
:
let i = 1;
const iter = serviceClient.listFileSystems();
let fileSystemItem = await iter.next();
while (!fileSystemItem.done) {
console.log(`FileSystem ${i++}: ${fileSystemItem.value.name}`);
fileSystemItem = await iter.next();
}
Esempio con byPage()
:
// passing optional maxPageSize in the page settings
let i = 1;
for await (const response of serviceClient.listFileSystems().byPage({ maxPageSize: 20 })) {
if (response.fileSystemItems) {
for (const fileSystem of response.fileSystemItems) {
console.log(`FileSystem ${i++}: ${fileSystem.name}`);
}
}
}
Esempio di uso del paging con un marcatore:
let i = 1;
let iterator = serviceClient.listFileSystems().byPage({ maxPageSize: 2 });
let response = (await iterator.next()).value;
// Prints 2 file system names
if (response.fileSystemItems) {
for (const fileSystem of response.fileSystemItems) {
console.log(`FileSystem ${i++}: ${fileSystem.name}`);
}
}
// Gets next marker
let marker = response.continuationToken;
// Passing next marker as continuationToken
iterator = serviceClient
.listContainers()
.byPage({ continuationToken: marker, maxPageSize: 10 });
response = (await iterator.next()).value;
// Prints 10 file system names
if (response.fileSystemItems) {
for (const fileSystem of response.fileSystemItems) {
console.log(`FileSystem ${i++}: ${fileSystem.name}`);
}
}
Vedere https://docs.microsoft.com/en-us/rest/api/storageservices/list-containers2
function listFileSystems(options?: ServiceListFileSystemsOptions): PagedAsyncIterableIterator<FileSystemItem, ServiceListFileSystemsSegmentResponse, PageSettings>
Parametri
- options
- ServiceListFileSystemsOptions
Restituisce
setProperties(BlobServiceProperties, ServiceSetPropertiesOptions)
Imposta le proprietà per l'endpoint del servizio BLOB di un account di archiviazione, incluse le proprietà per Analisi archiviazione, le regole CORS (Condivisione risorse tra le origini) e le impostazioni di eliminazione temporanea.
Vedere https://docs.microsoft.com/en-us/rest/api/storageservices/set-blob-service-properties
function setProperties(properties: BlobServiceProperties, options?: ServiceSetPropertiesOptions): Promise<ServiceSetPropertiesResponse>
Parametri
- properties
- DataLakeServiceProperties
- options
- ServiceSetPropertiesOptions
Opzioni per l'operazione Service Set Properties .Options to the Service Set Properties operation.
Restituisce
Promise<ServiceSetPropertiesResponse>
Dati di risposta per l'operazione Proprietà set di servizi.
undeleteFileSystem(string, string, ServiceUndeleteFileSystemOptions)
Ripristinare un file system eliminato in precedenza. Questa API è funzionante solo se l'eliminazione temporanea del contenitore è abilitata per l'account di archiviazione.
function undeleteFileSystem(deletedFileSystemName: string, deleteFileSystemVersion: string, options?: ServiceUndeleteFileSystemOptions): Promise<{ fileSystemClient: DataLakeFileSystemClient, fileSystemUndeleteResponse: ContainerUndeleteResponse }>
Parametri
- deletedFileSystemName
-
string
Nome del file system di origine.
- deleteFileSystemVersion
-
string
Nuovo nome del file system.
- options
- ServiceUndeleteFileSystemOptions
Opzioni per configurare l'operazione di ripristino del file system.
Restituisce
Promise<{ fileSystemClient: DataLakeFileSystemClient, fileSystemUndeleteResponse: ContainerUndeleteResponse }>