BatchDataFrameOperations 類別

針對 DataFrame 的批次記錄操作包裝器。

提供 createupdate,以及 delete 接受 pandas.DataFrame / pandas.Series 輸入並將其轉換為標準字典,然後在批次排隊前完成。 這讓資料科學呼叫者能直接將 DataFrame 輸入批次,無需手動轉換。

透過 batch.dataframe 存取。

範例:


   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()

建構函式

BatchDataFrameOperations(batch: _BatchContext)

參數

名稱 Description
batch
必要

方法

create

Enqueue 記錄由 pandas DataFrame 建立。

每一行都成為紀錄。 所有列都被綁在同一個 CreateMultiple 批次項目中(批次中的一個 HTTP 請求)。

範例:


   df = pd.DataFrame([{"name": "Contoso"}, {"name": "Fabrikam"}])
   batch.dataframe.create("account", df)
delete

從 PANDAS 一連串 GUID 中排隊記錄刪除。

範例:


   ids_series = pd.Series(["guid-1", "guid-2", "guid-3"])
   batch.dataframe.delete("account", ids_series)
update

從 pandas DataFrame 進行記錄更新排隊。

每一列代表一次更新。 該欄位 id_column 指定包含記錄 GUID。

範例:


   df = pd.DataFrame([
       {"accountid": "guid-1", "telephone1": "555-0100"},
       {"accountid": "guid-2", "telephone1": "555-0200"},
   ])
   batch.dataframe.update("account", df, id_column="accountid")

create

Enqueue 記錄由 pandas DataFrame 建立。

每一行都成為紀錄。 所有列都被綁在同一個 CreateMultiple 批次項目中(批次中的一個 HTTP 請求)。

範例:


   df = pd.DataFrame([{"name": "Contoso"}, {"name": "Fabrikam"}])
   batch.dataframe.create("account", df)
create(table: str, records: DataFrame) -> None

參數

名稱 Description
table
必要
str

資料表結構名稱(例如 "account")。

records
必要

DataFrame 中每一列都是要建立的記錄。

例外狀況

類型 Description

如果 records 不是 pandas DataFrame。

如果 records 是空的,或任一列沒有非空值。

delete

從 PANDAS 一連串 GUID 中排隊記錄刪除。

範例:


   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

參數

名稱 Description
table
必要
str

資料表結構名稱(例如 "account")。

ids
必要

一系列記錄 GUID 可刪除。

use_bulk_delete

當(預設值)和 ids 有多個值時True,使用動作BulkDelete

預設值: True

例外狀況

類型 Description

如果 ids 不是熊貓系列。

如果 ids 包含無效值。

update

從 pandas DataFrame 進行記錄更新排隊。

每一列代表一次更新。 該欄位 id_column 指定包含記錄 GUID。

範例:


   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

參數

名稱 Description
table
必要
str

資料表結構名稱(例如 "account")。

changes
必要

DataFrame 中,每列包含一個記錄 GUID 及需更新的欄位。

id_column
必要
str

包含記錄 GUID 的資料框架欄位名稱。

clear_nulls

當(預設)時 False ,NaN/None 值會被跳過。 當 True時,NaN/None 會 null 發送清場。

預設值: False

例外狀況

類型 Description

如果 changes 不是 pandas DataFrame。

如果 changes 是空的、 id_column 缺少或ID無效。