Query

yaml

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

Query Weaviate database with GraphQL.

Examples

Execute a GraphQL query to fetch data from a Weaviate database

yaml

id: weaviate_query
namespace: dev

tasks:
  - id: query
    type: io.kestra.plugin.weaviate.Query
    url: https://demo-cluster-id.weaviate.network
    apiKey: "{{ secret('WEAVIATE_API_KEY') }}"
    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: dev

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') }}"
    query: |
      {
        Get {
          Question(limit: 5, nearText: {concepts: ["biology"]}) {
            question
            answer
            category
          }
        }
      }

Properties

`fetchType`

Type: string
Dynamic: ❌
Required: ✔️
Default: STORE
Possible Values:
- STORE
- FETCH
- FETCH_ONE
- NONE

How you want to store the output data

FETCH_ONE outputs only the first row FETCH outputs all rows STORE stores all rows in a file NONE doesn't store any data. It's particularly useful when you execute DDL statements or run queries that insert data into another table e.g. using SELECT ... INSERT INTO statements.