aio 패키지
클래스
BlobClient |
특정 Blob과 상호 작용하는 클라이언트이지만 해당 Blob은 아직 존재하지 않을 수 있습니다. |
BlobLeaseClient |
새 BlobLeaseClient를 만듭니다. 이 클라이언트는 BlobClient 또는 ContainerClient에서 임대 작업을 제공합니다. |
BlobPrefix |
Blob 속성의 반복 가능입니다. 구분 기호를 사용할 때 walk_blobs 반환됩니다. 가상 Blob 디렉터리로 간주할 수 있습니다. |
BlobServiceClient |
계정 수준에서 Blob Service와 상호 작용하는 클라이언트입니다. 이 클라이언트는 계정 속성을 검색 및 구성하고 계정 내에서 컨테이너를 나열, 만들기 및 삭제하는 작업을 제공합니다. 특정 컨테이너 또는 Blob과 관련된 작업의 경우 get_client 함수를 사용하여 해당 엔터티에 대한 클라이언트를 검색할 수도 있습니다. |
ContainerClient |
특정 컨테이너와 상호 작용하는 클라이언트이지만 해당 컨테이너는 아직 존재하지 않을 수 있습니다. 이 컨테이너 내의 특정 Blob과 관련된 작업의 경우 함수를 사용하여 get_blob_client Blob 클라이언트를 검색할 수 있습니다. |
ExponentialRetry |
지수 재시도. 지수 재시도 개체를 생성합니다. initial_backoff 첫 번째 재시도에 사용됩니다. 후속 재시도는 initial_backoff + increment_power^retry_count 초 후에 다시 시도됩니다. 예를 들어 기본적으로 첫 번째 재시도는 15초 후, 두 번째 재시도는 (15+3^1) = 18초, 세 번째 후(15+3^2) = 24초 후에 발생합니다. |
LinearRetry |
선형 재시도. 선형 재시도 개체를 생성합니다. |
StorageStreamDownloader |
Azure Storage에서 다운로드할 스트리밍 개체입니다. |
함수
download_blob_from_url
Blob의 콘텐츠를 로컬 파일 또는 스트림에 다운로드합니다.
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
매개 변수
- credential
인증할 자격 증명입니다. Blob URL에 이미 SAS 토큰이 있거나 Blob이 공용인 경우 선택 사항입니다. 값은 SAS 토큰 문자열, azure.core.credentials에서 AzureSasCredential 또는 AzureNamedKeyCredential의 instance, 계정 공유 액세스 키 또는 azure.identity에서 TokenCredentials 클래스의 instance 수 있습니다. 리소스 URI에 이미 SAS 토큰이 포함된 경우 명시적 자격 증명을 위해 무시됩니다.
- 충돌하는 SAS 토큰이 ValueError를 발생시키는 AzureSasCredential의 경우를 제외하고. AzureNamedKeyCredential의 instance 사용하는 경우 "name"은 스토리지 계정 이름이고 "키"는 스토리지 계정 키여야 합니다.
- overwrite
- bool
로컬 파일이 이미 있는 경우 덮어쓸지 여부입니다. 기본값은 False 입니다. 이 경우 파일이 이미 있는 경우 ValueError가 발생합니다. True로 설정하면 기존 파일에 쓰려고 시도합니다. 스트림 핸들이 전달되면 이 값은 무시됩니다.
- max_concurrency
- int
다운로드할 병렬 연결 수입니다.
- offset
- int
Blob의 섹션을 다운로드하는 데 사용할 바이트 범위의 시작입니다. 길이가 제공되면 설정해야 합니다.
- length
- int
스트림에서 읽을 바이트 수입니다. 선택 사항이지만 최적의 성능을 위해 제공해야 합니다.
- validate_content
- bool
true이면 Blob의 각 청크에 대한 MD5 해시를 계산합니다. 스토리지 서비스는 전송된 해시와 함께 도착한 콘텐츠의 해시를 확인합니다. 이는 https 대신 https(기본값)를 사용하여 이미 유효성을 검사하는 경우 와이어에서 비트플립을 검색하는 데 주로 유용합니다. 이 MD5 해시는 blob에 저장되지 않습니다. 또한 사용하도록 설정하면 MD5 해시를 계산하려면 전체 블록을 버퍼링해야 하므로 메모리 효율적인 업로드 알고리즘이 사용되지 않습니다. 이렇게 하면 메모리 효율적인 알고리즘의 목적이 무효화됩니다.
반환 형식
upload_blob_to_url
지정된 URL에 데이터 업로드
데이터는 블록 Blob으로 업로드됩니다.
param str blob_url: Blob에 대한 전체 URI입니다. 여기에는 SAS 토큰도 포함될 수 있습니다.
param data: 업로드할 데이터입니다. 바이트, 텍스트, 반복 가능 개체 또는 파일과 같은 개체일 수 있습니다.
형식 데이터: 바이트 또는 str 또는 반복 가능
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]
매개 변수
- credential
인증할 자격 증명입니다. Blob URL에 이미 SAS 토큰이 있는 경우 선택 사항입니다. 값은 SAS 토큰 문자열, azure.core.credentials에서 AzureSasCredential 또는 AzureNamedKeyCredential의 instance, 계정 공유 액세스 키 또는 azure.identity에서 TokenCredentials 클래스의 instance 수 있습니다. 리소스 URI에 이미 SAS 토큰이 포함된 경우 명시적 자격 증명을 위해 무시됩니다.
- 충돌하는 SAS 토큰이 ValueError를 발생시키는 AzureSasCredential의 경우를 제외하고. AzureNamedKeyCredential의 instance 사용하는 경우 "name"은 스토리지 계정 이름이고 "키"는 스토리지 계정 키여야 합니다.
paramtype credential: Optional[Union[str, Dict[str, str], AzureNamedKeyCredential, AzureSasCredential, "TokenCredential"]] # pylint: disable=line-too-long
키워드(keyword) bool 덮어쓰기: 업로드할 Blob이 현재 데이터를 덮어쓸지 여부입니다. True이면 upload_blob_to_url 기존 데이터를 덮어씁 수 있습니다. False로 설정하면 ResourceExistsError로 작업이 실패합니다.
키워드(keyword) int max_concurrency: 다운로드할 병렬 연결 수입니다.
키워드(keyword) 길이: 스트림에서 읽을 바이트 수입니다. 선택 사항이지만 최적의 성능을 위해 제공해야 합니다.
키워드(keyword) dict(str,str) 메타데이터: Blob과 연결된 이름-값 쌍을 메타데이터로 사용합니다.
키워드(keyword) bool validate_content: true이면 Blob의 각 청크에 대한 MD5 해시를 계산합니다. 스토리지 서비스는 전송된 해시와 함께 도착한 콘텐츠의 해시를 확인합니다. 이는 https 대신 https(기본값)를 사용하여 이미 유효성을 검사하는 경우 와이어에서 비트플립을 검색하는 데 주로 유용합니다. 이 MD5 해시는 blob에 저장되지 않습니다. 또한 사용하도록 설정하면 MD5 해시를 계산하려면 전체 블록을 버퍼링해야 하므로 메모리 효율적인 업로드 알고리즘이 사용되지 않습니다. 이렇게 하면 메모리 효율적인 알고리즘의 목적이 무효화됩니다.
키워드(keyword) str encoding: 텍스트가 입력으로 제공되는 경우 사용할 인코딩입니다. 기본값은 UTF-8입니다.
returns: Blob 업데이트 속성 받아쓰기(Etag 및 마지막으로 수정됨)
rtype: dict(str, Any)
- blob_url
- data
Azure SDK for Python