delete_records

Built-in PostgreSQLおよびSQL Connectionで接続しているデータベース上のテーブルからレコードを削除します。

morph_lib.database

# 📦 Package: morph_lib.database
# 🛠️ Function: delete_records

delete_records(
	data: pd.DataFrame,
	primary_keys: List[str]
	table_name: str,
	connection: Optional[str]
) -> None

対応データベース

PostgreSQL
MySQL
Snowflake
BigQuery
Amazon Redshift

Parameters

pd.DataFrame

required

関数に渡す実データ。primary_keysで指定するカラムは必ず存在している必要があります。

List[str]

required

テーブルのPrimary Keyとなるカラム名を指定する。

str

required

テーブル名を指定する。

str

画面で登録したbuiltin以外のconnectionの向き先 (optional)※ 指定をしない場合はbuilt-in postgresqlに設定されます。

Example

from morph_lib.database import delete_records

@morph.func
@morph.load_data("user_data")
def func_name(context):
	user_data: pd.DataFrame = context.data["user_data"]
	delete_records(
		user_data,
		["user_id"]
		"user",
	)

フレームワーク

SQL

Python

morph_lib.database

morph_lib.api

morph_lib.stream

CLI

Deprecated

delete_records

Parameters

Example

​Parameters

​Example

Parameters

Example