Bagikan melalui

aio Paket

  • Referensi

Kelas

BlobClient

Klien untuk berinteraksi dengan blob tertentu, meskipun blob tersebut mungkin belum ada.
BlobLeaseClient

Membuat BlobLeaseClient baru.

Klien ini menyediakan operasi sewa pada BlobClient atau ContainerClient.
BlobPrefix

Iterable properti Blob.

Dikembalikan dari walk_blobs saat pemisah digunakan. Dapat dianggap sebagai direktori blob virtual.
BlobServiceClient

Klien untuk berinteraksi dengan Blob Service di tingkat akun.

Klien ini menyediakan operasi untuk mengambil dan mengonfigurasi properti akun serta mencantumkan, membuat dan menghapus kontainer dalam akun. Untuk operasi yang berkaitan dengan kontainer atau blob tertentu, klien untuk entitas tersebut juga dapat diambil menggunakan fungsi get_client .
ContainerClient

Klien untuk berinteraksi dengan kontainer tertentu, meskipun kontainer tersebut mungkin belum ada.

Untuk operasi yang berkaitan dengan blob tertentu dalam kontainer ini, klien blob dapat diambil menggunakan fungsi .get_blob_client
ExponentialRetry

Percobaan ulang eksponensial.

Membuat objek percobaan kembali Eksponensial. initial_backoff digunakan untuk coba lagi pertama kali. Percobaan ulang berikutnya dicoba kembali setelah initial_backoff + increment_power^retry_count detik. Misalnya, secara default percobaan ulang pertama terjadi setelah 15 detik, yang kedua setelah (15+3^1) = 18 detik, dan yang ketiga setelah (15+3^2) = 24 detik.
LinearRetry

Coba lagi linear.

Membuat objek coba lagi Linear.
StorageStreamDownloader

Objek streaming untuk diunduh dari Azure Storage.

Fungsi

download_blob_from_url

Unduh konten blob ke file atau aliran lokal.

async download_blob_from_url(blob_url: str, output: str, credential: Optional[Union[str, Dict[str, str], AzureNamedKeyCredential, AzureSasCredential, "TokenCredential"]] # pylint: disable=line-too-long = None, **kwargs) -> None

Parameter

blob_url
str
Diperlukan

URI penuh ke blob. Ini juga dapat mencakup token SAS.

output
str atau <xref:<xref:writable stream>>
Diperlukan

Tempat data harus diunduh. Ini bisa berupa jalur file untuk ditulis, atau handel IO terbuka untuk ditulis.

credential
nilai default: None

Kredensial yang digunakan untuk mengautentikasi. Ini bersifat opsional jika URL blob sudah memiliki token SAS atau blob bersifat publik. Nilainya dapat berupa string token SAS, instans AzureSasCredential atau AzureNamedKeyCredential dari azure.core.credentials, kunci akses bersama akun, atau instans kelas TokenCredentials dari azure.identity. Jika URI sumber daya sudah berisi token SAS, ini akan diabaikan demi kredensial eksplisit

  • kecuali dalam kasus AzureSasCredential, di mana token SAS yang bertentangan akan menaikkan ValueError. Jika menggunakan instans AzureNamedKeyCredential, "nama" harus menjadi nama akun penyimpanan, dan "kunci" harus menjadi kunci akun penyimpanan.
overwrite
bool

Apakah file lokal harus ditimpa jika sudah ada. Nilai defaultnya adalah False - dalam hal ini ValueError akan dinaikkan jika file sudah ada. Jika diatur ke True, upaya akan dilakukan untuk menulis ke file yang ada. Jika handel aliran diteruskan, nilai ini diabaikan.

max_concurrency
int

Jumlah koneksi paralel yang akan diunduh.

offset
int

Mulai rentang byte yang digunakan untuk mengunduh bagian blob. Harus diatur jika panjang disediakan.

length
int

Jumlah byte yang akan dibaca dari aliran. Ini bersifat opsional, tetapi harus disediakan untuk performa yang optimal.

validate_content
bool

Jika true, menghitung hash MD5 untuk setiap gugus blob. Layanan penyimpanan memeriksa hash konten yang telah tiba dengan hash yang dikirim. Ini terutama berharga untuk mendeteksi bitflips pada kawat jika menggunakan http alih-alih https sebagai https (default) sudah akan memvalidasi. Perhatikan bahwa hash MD5 ini tidak disimpan dengan blob. Perhatikan juga bahwa jika diaktifkan, algoritma pengunggahan yang hemat memori tidak akan digunakan, karena komputasi hash MD5 memerlukan buffering seluruh blok, dan melakukannya mengalahkan tujuan algoritma yang hemat memori.

Tipe hasil

None

upload_blob_to_url

Mengunggah data ke URL tertentu

Data akan diunggah sebagai blob blok.

str param blob_url: URI penuh ke blob. Ini juga dapat mencakup token SAS.

data param: Data yang akan diunggah. Ini bisa berupa byte, teks, objek yang dapat diulang atau seperti file.

jenis data: byte atau str atau Iterable

async upload_blob_to_url(blob_url: str, data: Union[Iterable[AnyStr], IO[AnyStr]], credential: Optional[Union[str, Dict[str, str], AzureNamedKeyCredential, AzureSasCredential, "TokenCredential"]] # pylint: disable=line-too-long = None, **kwargs) -> dict[str, Any]

Parameter

credential
nilai default: None

Kredensial yang digunakan untuk mengautentikasi. Ini bersifat opsional jika URL blob sudah memiliki token SAS. Nilainya dapat berupa string token SAS, instans AzureSasCredential atau AzureNamedKeyCredential dari azure.core.credentials, kunci akses bersama akun, atau instans kelas TokenCredentials dari azure.identity. Jika URI sumber daya sudah berisi token SAS, ini akan diabaikan demi kredensial eksplisit

  • kecuali dalam kasus AzureSasCredential, di mana token SAS yang bertentangan akan menaikkan ValueError. Jika menggunakan instans AzureNamedKeyCredential, "nama" harus menjadi nama akun penyimpanan, dan "kunci" harus menjadi kunci akun penyimpanan.

kredensial paramtype: Opsional[Union[str, Dict[str, str], AzureNamedKeyCredential, AzureSasCredential, "TokenCredential"]] # pylint: disable=line-too-long

timpa bool kata kunci: Apakah blob yang akan diunggah harus menimpa data saat ini. Jika True, upload_blob_to_url akan menimpa data yang ada. Jika diatur ke False, operasi akan gagal dengan ResourceExistsError.

kata kunci int max_concurrency: Jumlah koneksi paralel yang akan diunduh.

panjang int kata kunci: Jumlah byte yang akan dibaca dari aliran. Ini bersifat opsional, tetapi harus disediakan untuk performa yang optimal.

metadata dict(str,str): Pasangan nilai nama yang terkait dengan blob sebagai metadata.

kata kunci bool validate_content: Jika true, menghitung hash MD5 untuk setiap gugus blob. Layanan penyimpanan memeriksa hash konten yang telah tiba dengan hash yang dikirim. Ini terutama berharga untuk mendeteksi bitflips pada kawat jika menggunakan http alih-alih https sebagai https (default) sudah akan memvalidasi. Perhatikan bahwa hash MD5 ini tidak disimpan dengan blob. Perhatikan juga bahwa jika diaktifkan, algoritma pengunggahan yang hemat memori tidak akan digunakan, karena komputasi hash MD5 memerlukan buffering seluruh blok, dan melakukannya mengalahkan tujuan algoritma yang hemat memori.

pengodean str kata kunci: Pengodean untuk digunakan jika teks disediakan sebagai input. Default ke UTF-8.

returns: Dict properti yang diperbarui blob (Etag dan terakhir dimodifikasi)

rtype: dict(str, Any)

blob_url
data