BatchDataFrameOperations Klasa
Otoki zorientowane na ramki danych na potrzeby operacji rekordów wsadowych.
Udostępnia createelement , updatei , który delete akceptuje pandas.DataFrame / pandas.Series dane wejściowe i konwertuje je na standardowe dykty przed kolejkowaniem w partii. Dzięki temu osoby wywołujące dane są przekazywane bezpośrednio do partii bez ręcznej konwersji.
Dostęp jest uzyskiwany za pośrednictwem batch.dataframe.
Example:
import pandas as pd
batch = client.batch.new()
df = pd.DataFrame([
{"name": "Contoso", "telephone1": "555-0100"},
{"name": "Fabrikam", "telephone1": "555-0200"},
])
batch.dataframe.create("account", df)
result = batch.execute()
Konstruktor
BatchDataFrameOperations(batch: _BatchContext)
Parametry
| Nazwa | Opis |
|---|---|
|
batch
Wymagane
|
|
Metody
| create |
Rekord enqueue tworzy się na podstawie ramki danych biblioteki pandas. Każdy wiersz staje się rekordem. Wszystkie wiersze są umieszczane w jednym Example:
|
| delete |
Rekord enqueue usuwa z serii identyfikatorów GUID biblioteki pandas. Example:
|
| update |
Aktualizacje rekordów kolejki z ramki danych biblioteki pandas. Każdy wiersz reprezentuje aktualizację. Określa, która kolumna Example:
|
create
Rekord enqueue tworzy się na podstawie ramki danych biblioteki pandas.
Każdy wiersz staje się rekordem. Wszystkie wiersze są umieszczane w jednym CreateMultiple elemencie wsadowym (jedno żądanie HTTP w partii).
Example:
df = pd.DataFrame([{"name": "Contoso"}, {"name": "Fabrikam"}])
batch.dataframe.create("account", df)
create(table: str, records: DataFrame) -> None
Parametry
| Nazwa | Opis |
|---|---|
|
table
Wymagane
|
Nazwa schematu tabeli (np. |
|
records
Wymagane
|
Ramka danych, w której każdy wiersz jest rekordem do utworzenia. |
Wyjątki
| Typ | Opis |
|---|---|
|
Jeśli |
|
|
Jeśli |
delete
Rekord enqueue usuwa z serii identyfikatorów GUID biblioteki pandas.
Example:
ids_series = pd.Series(["guid-1", "guid-2", "guid-3"])
batch.dataframe.delete("account", ids_series)
delete(table: str, ids: Series, use_bulk_delete: bool = True) -> None
Parametry
| Nazwa | Opis |
|---|---|
|
table
Wymagane
|
Nazwa schematu tabeli (np. |
|
ids
Wymagane
|
Seria identyfikatorów GUID rekordów do usunięcia. |
|
use_bulk_delete
|
Jeśli Domyślna wartość: True
|
Wyjątki
| Typ | Opis |
|---|---|
|
Jeśli |
|
|
Jeśli |
update
Aktualizacje rekordów kolejki z ramki danych biblioteki pandas.
Każdy wiersz reprezentuje aktualizację. Określa, która kolumna id_column zawiera identyfikatory GUID rekordu.
Example:
df = pd.DataFrame([
{"accountid": "guid-1", "telephone1": "555-0100"},
{"accountid": "guid-2", "telephone1": "555-0200"},
])
batch.dataframe.update("account", df, id_column="accountid")
update(table: str, changes: DataFrame, id_column: str, clear_nulls: bool = False) -> None
Parametry
| Nazwa | Opis |
|---|---|
|
table
Wymagane
|
Nazwa schematu tabeli (np. |
|
changes
Wymagane
|
Ramka danych, w której każdy wiersz zawiera identyfikator GUID rekordu i pola do zaktualizowania. |
|
id_column
Wymagane
|
Nazwa kolumny DataFrame zawierającej identyfikatory GUID rekordów. |
|
clear_nulls
|
Gdy Domyślna wartość: False
|
Wyjątki
| Typ | Opis |
|---|---|
|
Jeśli |
|
|
Jeśli |