BatchDataFrameOperations Osztály
DataFrame-orientált burkoló kötegrekord-műveletekhez.
Megadja create, updateés delete fogadja el pandas.DataFrame / pandas.Series a bemeneteket, és szabványos diktálásokká alakítja őket, mielőtt a kötegbe lépne. Ez lehetővé teszi, hogy az adatelemzési hívók manuális átalakítás nélkül közvetlenül egy kötegbe táplálják a DataFrame-eket.
Elérhető ezen keresztül: 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)
Paraméterek
| Name | Description |
|---|---|
|
batch
Kötelező
|
|
Metódusok
| create |
Az enqueue rekord egy pandas DataFrame-ből jön létre. Minden sor rekord lesz. Minden sor egyetlen Example:
|
| delete |
Az enqueue rekord töröl egy pandas-sorozat grafikus felhasználói felületéről. Example:
|
| update |
Rekordfrissítések leküldése pandas DataFrame-ből. Minden sor egy frissítést jelöl. Megadja Example:
|
create
Az enqueue rekord egy pandas DataFrame-ből jön létre.
Minden sor rekord lesz. Minden sor egyetlen CreateMultiple kötegelembe van csomagolva (a kötegben egy HTTP-kérés).
Example:
df = pd.DataFrame([{"name": "Contoso"}, {"name": "Fabrikam"}])
batch.dataframe.create("account", df)
create(table: str, records: DataFrame) -> None
Paraméterek
| Name | Description |
|---|---|
|
table
Kötelező
|
Táblaséma neve (pl. |
|
records
Kötelező
|
DataFrame, ahol minden sor létrehozandó rekord. |
Kivételek
| Típus | Description |
|---|---|
|
Ha |
|
|
Ha |
delete
Az enqueue rekord töröl egy pandas-sorozat grafikus felhasználói felületéről.
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
Paraméterek
| Name | Description |
|---|---|
|
table
Kötelező
|
Táblaséma neve (pl. |
|
ids
Kötelező
|
Törölni kívánt rekordGUID-k sorozata. |
|
use_bulk_delete
|
Ha Alapértelmezett érték: True
|
Kivételek
| Típus | Description |
|---|---|
|
Ha |
|
|
Ha |
update
Rekordfrissítések leküldése pandas DataFrame-ből.
Minden sor egy frissítést jelöl. Megadja id_column , hogy melyik oszlop tartalmazza a rekord GUID-jait.
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
Paraméterek
| Name | Description |
|---|---|
|
table
Kötelező
|
Táblaséma neve (pl. |
|
changes
Kötelező
|
DataFrame, ahol minden sor tartalmaz egy rekord GUID azonosítóját és a frissíteni kívánt mezőket. |
|
id_column
Kötelező
|
A rekordGUID-ket tartalmazó DataFrame oszlop neve. |
|
clear_nulls
|
Ha Alapértelmezett érték: False
|
Kivételek
| Típus | Description |
|---|---|
|
Ha |
|
|
Ha |