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

data · pd.DataFrame · required

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

table_name · str · required

Specify the table name.

connection · 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",
	)