airflow.providers.pgvector.operators.pgvector

Module Contents

Classes

PgVectorIngestOperator

This operator is designed for ingesting data into a PostgreSQL database with pgvector support.
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.

Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

Was this entry helpful?