airflow.providers.weaviate.operators.weaviate

Module Contents

Classes

WeaviateIngestOperator

Operator that store vector in the Weaviate class.
class airflow.providers.weaviate.operators.weaviate.WeaviateIngestOperator(conn_id, class_name, input_json, **kwargs)[source]

Bases: airflow.models.BaseOperator

Operator that store vector in the Weaviate class.

See also

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

Operator that accepts input json to generate embeddings on or accepting provided custom vectors and store them in the Weaviate class.

Parameters

  • conn_id (str) – The Weaviate connection.

  • class_name (str) – The Weaviate class to be used for storing the data objects into.

  • input_json (list[dict[str, Any]]) – The JSON representing Weaviate data objects to generate embeddings on (or provides custom vectors) and store them in the Weaviate class. Either input_json or input_callable should be provided.

template_fields: Sequence[str] = ('input_json',)[source]
hook()[source]

Return an instance of the WeaviateHook.

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?