BlobQueryReader Osztály

Streamelési objektum a lekérdezési eredmények olvasásához.

Öröklődés

builtins.object

BlobQueryReader

Konstruktor

BlobQueryReader(name=None, container=None, errors=None, record_delimiter='\n', encoding=None, headers=None, response=None, error_cls=None)

Paraméterek

Name	Description
name	alapértelmezett érték: None
container	alapértelmezett érték: None
errors	alapértelmezett érték: None
record_delimiter	alapértelmezett érték:
encoding	alapértelmezett érték: None
headers	alapértelmezett érték: None
response	alapértelmezett érték: None
error_cls	alapértelmezett érték: None

Változók

Name	Description
name	str A lekérdezett blob neve.
container	str Annak a tárolónak a neve, ahol a blob található.
response_headers	dict A gyors lekérdezési kérelem response_headers.
record_delimiter	bytes A vonalak vagy rekordok adatokkal való elválasztásához használt elválasztó. A records metódus ezeket a vonalakat egy generátoron keresztül adja vissza.

Metódusok

readall	Az összes lekérdezési eredményt visszaadja. Ez a művelet addig blokkolódik, amíg az összes adat le nem töltődik. Ha a kódolás konfigurálva van , akkor a rendszer az egyes rekordok dekódolására fogja használni a beérkező rekordokat.
readinto	Töltse le a lekérdezés eredményét egy streambe.
records	Egy rekordgenerátort ad vissza a lekérdezés eredményéhez. A rekordok sorról sorra jelennek meg. Ha a kódolás konfigurálva van , akkor a rendszer az egyes rekordok dekódolására fogja használni a beérkező rekordokat.

readall

Az összes lekérdezési eredményt visszaadja.

Ez a művelet addig blokkolódik, amíg az összes adat le nem töltődik. Ha a kódolás konfigurálva van , akkor a rendszer az egyes rekordok dekódolására fogja használni a beérkező rekordokat.

readall() -> bytes | str

Válaszok

Típus	Description
Union[bytes, str]	A lekérdezés eredménye.

readinto

Töltse le a lekérdezés eredményét egy streambe.

readinto(stream: IO) -> None

Paraméterek

Name	Description
stream Kötelező	IO A letöltéshez használt stream. Ez lehet egy megnyitott fájlkezelő vagy bármilyen írható stream.

Válaszok

Típus	Description
	None

records

Egy rekordgenerátort ad vissza a lekérdezés eredményéhez.

A rekordok sorról sorra jelennek meg. Ha a kódolás konfigurálva van , akkor a rendszer az egyes rekordok dekódolására fogja használni a beérkező rekordokat.

records() -> Iterable[bytes | str]

Válaszok

Típus	Description
Iterable[Union[bytes, str]]	A lekérdezés eredményének rekordgenerátora.