airflow.providers.pgvector.operators.pgvector

PgVectorIngestOperator

这个 Operator 设计用于将数据摄取到支持 pgvector 的 PostgreSQL 数据库中。

模块内容

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

基类: airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator

这个 Operator 设计用于将数据摄取到支持 pgvector 的 PostgreSQL 数据库中。

它继承自 SQLExecuteQueryOperator,并通过在执行查询前向数据库连接注册 pgvector 数据类型来扩展其功能。

另请参阅

有关如何使用此 Operator 的更多信息,请参阅指南: PgVectorIngestOperator

execute(context)[source]

创建 Operator 时派生此方法。

Context 是用于渲染 jinja 模板的相同字典。

有关更多 context 信息,请参阅 get_template_context。

本条目有帮助吗?