Weaviate Query

Weaviate Query
Certified
Run GraphQL query against Weaviate

Executes a raw GraphQL query on Weaviate. Defaults to storing all rows to Kestra storage as ION; other fetch modes can return rows inline or skip storage.

yaml
type: io.kestra.plugin.weaviate.Query

Examples

Execute a GraphQL query to fetch data from a Weaviate database.

yaml
id: weaviate_query
namespace: company.team

tasks:
  - id: query
    type: io.kestra.plugin.weaviate.Query
    url: https://demo-cluster-id.weaviate.network
    apiKey: "{{ secret('WEAVIATE_API_KEY') }}"
    fetchType: FETCH
    query: |
      {
        Get {
          Question(limit: 5) {
            question
            answer
            category
          }
        }
      }

Query data from a Weaviate database using Generative Search with OpenAI

yaml
id: weaviate_generative_search
namespace: company.team

tasks:
  - id: query
    type: io.kestra.plugin.weaviate.Query
    url: https://demo-cluster-id.weaviate.network
    apiKey: "{{ secret('WEAVIATE_API_KEY') }}"
    headers:
      X-OpenAI-Api-Key: "{{ secret('OPENAI_API_KEY') }}"
    fetchType: FETCH
    query: |
      {
        Get {
          Question(limit: 5, nearText: {concepts: ["biology"]}) {
            question
            answer
            category
          }
        }
      }

Properties

query *string

Min length1

GraphQL query

url *string

Min length1

Configure Weaviate endpoint URL

Full http or https host for the Weaviate cluster, including port when not default. Example: localhost: 8080 or https://cluster-id.weaviate.network

apiKey string

Provide managed cluster API key

Optional bearer-style key for hosted Weaviate; if omitted, requests use anonymous access.

fetchType string

DefaultSTORE

Possible Values

STOREFETCHFETCH_ONENONE

Select fetch behavior

Defaults to STORE (writes all rows to Kestra storage as ION and returns the URI). FETCH returns all rows inline, FETCH_ONE returns the first row, NONE skips result materialization for DDL-type queries.

headers object

Set custom request headers

Key/value headers appended to every call, e.g. extra auth tokens for upstream services.

pluginDefaultsRef string

Reference (ref) of the pluginDefaults to apply to this task.

Outputs

row object

Map containing the first row of fetched data.

Only populated if using fetchType=FETCH_ONE.

rows array

List containing the fetched data.

Only populated if using fetchType=FETCH.

size integer

The number of fetched rows.

uri string

Formaturi

Kestra's internal storage URI of the stored data.

Only populated if using fetchType=STORE.

Liquibase

Tasks that run Liquibase change management commands.

Data

PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.

Data

Weaviate QueryCertifiedRun GraphQL query against Weaviate

Weaviate Query

More Plugins in this Category

Liquibase

PostgreSQL

Weaviate Query
Certified
Run GraphQL query against Weaviate