airflow.providers.pgvector.operators.pgvector

Classes

PgVectorIngestOperator

This operator is designed for ingesting data into a PostgreSQL database with pgvector support.

Module Contents

class airflow.providers.pgvector.operators.pgvector.PgVectorIngestOperator(*args, **kwargs)[source]

Bases: airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator

This operator is designed for ingesting data into a PostgreSQL database with pgvector support.

It inherits from the SQLExecuteQueryOperator and extends its functionality by registering the pgvector data type with the database connection before executing queries.

See also

For more information on how to use this operator, take a look at the guide: PgVectorIngestOperator

execute(context)[source]

Derive when creating an operator.

The main method to execute the task. Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

Was this entry helpful?