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 CreateMultiple elemencie wsadowym (jedno żądanie HTTP w partii).

Example:


   df = pd.DataFrame([{"name": "Contoso"}, {"name": "Fabrikam"}])
   batch.dataframe.create("account", df)
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)
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")

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
str

Nazwa schematu tabeli (np. "account").

records
Wymagane

Ramka danych, w której każdy wiersz jest rekordem do utworzenia.

Wyjątki

Typ Opis

Jeśli records nie jest to ramka danych biblioteki pandas.

Jeśli records jest pusty lub żaden wiersz nie ma wartości innych niż null.

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
str

Nazwa schematu tabeli (np. "account").

ids
Wymagane

Seria identyfikatorów GUID rekordów do usunięcia.

use_bulk_delete

Jeśli True (wartość domyślna) i ids ma wiele wartości, użyj BulkDelete akcji .

Domyślna wartość: True

Wyjątki

Typ Opis

Jeśli ids nie jest serią pandas.

Jeśli ids zawiera nieprawidłowe wartości.

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
str

Nazwa schematu tabeli (np. "account").

changes
Wymagane

Ramka danych, w której każdy wiersz zawiera identyfikator GUID rekordu i pola do zaktualizowania.

id_column
Wymagane
str

Nazwa kolumny DataFrame zawierającej identyfikatory GUID rekordów.

clear_nulls

Gdy False (ustawienie domyślne), wartości NaN/None są pomijane. Gdy Truefunkcja NaN/None wysyła null do wyczyszczenia pola.

Domyślna wartość: False

Wyjątki

Typ Opis

Jeśli changes nie jest to ramka danych biblioteki pandas.

Jeśli changes jest pusty, id_column brakuje identyfikatorów lub identyfikatory są nieprawidłowe.