insert_records

Inserts data into a table in the database connected with built-in PostgreSQL and SQL Connection.

morph_lib.database

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

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

対応データベース

PostgreSQL
MySQL
Snowflake
BigQuery
Amazon Redshift

Parameters

pd.DataFrame

required

The actual data to be passed to the function. The columns specified in primary_keys must always be present.

str

required

Specify the table name.

str

The destination of the connection other than the builtin registered on the screen (optional)

If not specified, it will be set to built-in postgresql.

Example

from morph_lib.database import insert_records

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

execute_sql update_records

Framework

SQL

Python

morph_lib.database

morph_lib.api

morph_lib.stream

CLI

Deprecated

insert_records

Parameters

Example

​Parameters

​Example

Parameters

Example