CloudQueryCLI | Kestra

CloudQueryCLI

Run CloudQuery CLI commands

yaml
type: io.kestra.plugin.cloudquery.CloudQueryCLI

Examples

yaml
id: cloudquery_sync_cli
namespace: company.team

tasks:
  - id: hn_to_duckdb
    type: io.kestra.plugin.cloudquery.CloudQueryCLI
    env:
      CLOUDQUERY_API_KEY: "{{ secret('CLOUDQUERY_API_KEY') }}"
    inputFiles:
      config.yml: |
        kind: source
        spec:
          name: hackernews
          path: cloudquery/hackernews
          version: v3.0.13
          tables: ["*"]
          backend_options:
            table_name: cq_cursor
            connection: "@@plugins.duckdb.connection"
          destinations:
            - "duckdb"
          spec:
            item_concurrency: 100
            start_time: "{{ now() | dateAdd(-1, 'DAYS') }}"
          ---
          kind: destination
          spec:
            name: duckdb
            path: cloudquery/duckdb
            version: v4.2.10
            write_mode: overwrite-delete-stale
            spec:
              connection_string: hn.db
    commands:
      - cloudquery sync config.yml --log-console

Properties

commands *array

SubTypestring

containerImage string

Defaultghcr.io/cloudquery/cloudquery:latest

env object

SubTypestring

inputFiles objectstring

namespaceFiles

Definitions

io.kestra.core.models.tasks.NamespaceFiles

enabledbooleanstring

Defaulttrue

excludearray

SubTypestring

folderPerNamespacebooleanstring

Defaultfalse

ifExistsstring

DefaultOVERWRITE

Possible Values

OVERWRITEFAILWARNIGNORE

includearray

SubTypestring

namespacesarray

SubTypestring

Default["{{flow.namespace}}"]

outputFiles array

SubTypestring

taskRunner

Definitions

Run a task in a Docker container.

Example

yaml
id: simple_shell_example
namespace: company.team

tasks:
  - id: shell
    type: io.kestra.plugin.scripts.shell.Commands
    taskRunner:
      type: io.kestra.plugin.scripts.runner.docker.Docker
    commands:
    - echo "Hello World"

yaml
id: shell_example_with_files
namespace: company.team

inputs:
  - id: file
    type: FILE

tasks:
  - id: shell
    type: io.kestra.plugin.scripts.shell.Commands
    inputFiles:
      data.txt: "{{ inputs.file }}"
    outputFiles:
      - "*.txt"
    containerImage: centos
    taskRunner:
      type: io.kestra.plugin.scripts.runner.docker.Docker
    commands:
    - cp {{ workingDir }}/data.txt {{ workingDir }}/out.txt

yaml
id: allocate_memory_to_python_script
namespace: company.team

tasks:
  - id: script
    type: io.kestra.plugin.scripts.python.Script
    taskRunner:
      type: io.kestra.plugin.scripts.runner.docker.Docker
      pullPolicy: IF_NOT_PRESENT
      cpu:
        cpus: 1
      memory: 
        memory: "512Mb"
    containerImage: ghcr.io/kestra-io/kestrapy:latest
    script: |
      from kestra import Kestra
      
      data = dict(message="Hello from Kestra!")
      Kestra.outputs(data)

type*object

configstringobject

cpu

io.kestra.plugin.scripts.runner.docker.Cpu

cpusnumberstring

credentials

Credentials for a private container registry.

authstring

identityTokenstring

passwordstring

registrystring

registryTokenstring

usernamestring

deletebooleanstring

Defaulttrue

deviceRequestsarray

A request for devices to be sent to device drivers.

capabilitiesarray

SubTypearray

countintegerstring

deviceIdsarray

SubTypestring

driverstring

optionsobject

SubTypestring

entryPointarray

SubTypestring

Default

[
  ""
]

extraHostsarray

SubTypestring

fileHandlingStrategystring

DefaultVOLUME

Possible Values

MOUNTVOLUME

hoststring

killGracePeriodstring

DefaultPT0S

Formatduration

memory

io.kestra.plugin.scripts.runner.docker.Memory

kernelMemorystring

memorystring

memoryReservationstring

memorySwapstring

memorySwappinessstring

oomKillDisablebooleanstring

networkModestring

portBindingsarray

SubTypestring

privilegedbooleanstring

pullPolicyobject

resumebooleanstring

Defaulttrue

shmSizestring

userstring

versionstring

volumesarray

SubTypestring

waitbooleanstring

Defaulttrue

Run tasks as local subprocesses on the worker.

Example

yaml
id: new_shell
namespace: company.team

tasks:
  - id: shell
    type: io.kestra.plugin.scripts.shell.Commands
    taskRunner:
      type: io.kestra.plugin.core.runner.Process
    commands:
      - echo "Hello World"

yaml
id: before_commands_example
namespace: company.team

inputs:
  - id: url
    type: URI
    defaults: https://jsonplaceholder.typicode.com/todos/1

tasks:
  - id: transform
    type: io.kestra.plugin.scripts.python.Script
    taskRunner:
      type: io.kestra.plugin.core.runner.Process
    beforeCommands:
      - pip install kestra requests --break-system-packages
    script: |
      import requests
      from kestra import Kestra

      url = "{{ inputs.url }}"

      response = requests.get(url)
      print('Status Code:', response.status_code)
      Kestra.outputs(response.json())

yaml
id: new_shell_with_file
namespace: company.team

inputs:
  - id: file
    type: FILE

tasks:
  - id: shell
    type: io.kestra.plugin.scripts.shell.Commands
    inputFiles:
      data.txt: "{{inputs.file}}"
    outputFiles:
      - out.txt
    taskRunner:
      type: io.kestra.plugin.core.runner.Process
    commands:
      - cp {{workingDir}}/data.txt {{workingDir}}/out.txt

type*object

versionstring

Task runner that executes a task inside a job in Azure Batch.

Example

yaml
id: new_shell
namespace: company.team

tasks:
  - id: shell
    type: io.kestra.plugin.scripts.shell.Commands
    taskRunner:
      type: io.kestra.plugin.ee.azure.runner.Batch
      account: "{{secrets.account}}"
      accessKey: "{{secrets.accessKey}}"
      endpoint: "{{secrets.endpoint}}"
      poolId: "{{vars.poolId}}"
    commands:
      - echo "Hello World"

yaml
id: new_shell_with_file
namespace: company.team

inputs:
  - id: file
    type: FILE

tasks:
  - id: shell
    type: io.kestra.plugin.scripts.shell.Commands
    inputFiles:
      data.txt: "{{inputs.file}}"
    outputFiles:
      - out.txt
    containerImage: centos
    taskRunner:
      type: io.kestra.plugin.azure.ee.runner.Batch
      account: "{{secrets.account}}"
      accessKey: "{{secrets.accessKey}}"
      endpoint: "{{secrets.endpoint}}"
      poolId: "{{vars.poolId}}"
      blobStorage:
        connectionString: "{{secrets.connectionString}}"
        containerName: "{{vars.containerName}}"
    commands:
      - cp {{workingDir}}/data.txt {{workingDir}}/out.txt

yaml
id: azure_batch_runner
namespace: company.team

variables:
  pool_id: poolId
  container_name: containerName

tasks:
  - id: scrape_environment_info
    type: io.kestra.plugin.scripts.python.Commands
    containerImage: ghcr.io/kestra-io/pydata:latest
    taskRunner:
      type: io.kestra.plugin.ee.azure.runner.Batch
      account: "{{ secret('AZURE_ACCOUNT') }}"
      accessKey: "{{ secret('AZURE_ACCESS_KEY') }}"
      endpoint: "{{ secret('AZURE_ENDPOINT') }}"
      poolId: "{{ vars.pool_id }}"
      blobStorage:
        containerName: "{{ vars.container_name }}"
        connectionString: "{{ secret('AZURE_CONNECTION_STRING') }}"
    commands:
      - python {{ workingDir }}/main.py
    namespaceFiles:
      enabled: true
    outputFiles:
      - environment_info.json
    inputFiles:
      main.py: |
        import platform
        import socket
        import sys
        import json

        from kestra import Kestra

        print("Hello from Azure Batch and kestra!")

        def print_environment_info():
            print(f"Host's network name: {platform.node()}")
            print(f"Python version: {platform.python_version()}")
            print(f"Platform information (instance type): {platform.platform()}")
            print(f"OS/Arch: {sys.platform}/{platform.machine()}")

            env_info = {
                "host": platform.node(),
                "platform": platform.platform(),
                "OS": sys.platform,
                "python_version": platform.python_version(),
            }
            Kestra.outputs(env_info)

            filename = 'environment_info.json'
            with open(filename, 'w') as json_file:
                json.dump(env_info, json_file, indent=4)

        if __name__ == '__main__':
          print_environment_info()

account*string

endpoint*string

poolId*string

type*object

Possible Values

io.kestra.plugin.ee.azure.runner.Batchio.kestra.plugin.azure.runner.Batch

accessKeystring

blobStorage

io.kestra.plugin.ee.azure.storage.blob.models.BlobStorageForBatch

containerName*string

connectionStringstring

endpointstring

sharedKeyAccountAccessKeystring

sharedKeyAccountNamestring

completionCheckIntervalstring

DefaultPT5S

deletebooleanstring

Defaulttrue

registry

io.kestra.plugin.ee.azure.batch.models.ContainerRegistry

identityReference

io.kestra.plugin.ee.azure.batch.models.ComputeNodeIdentityReference

resourceIdstring

passwordstring

registryServerstring

userNamestring

resumebooleanstring

Defaulttrue

streamLogsbooleanstring

Defaultfalse

syncWorkingDirectorybooleanstring

Defaultfalse

versionstring

waitUntilCompletionstring

DefaultPT1H

Task runner that executes a task inside a job in AWS Batch.

Example

yaml
id: run_container
namespace: company.team

variables:
  region: eu-west-2
  computeEnvironmentArn: "arn:aws:batch:eu-central-1:123456789012:compute-environment/kestraFargateEnvironment"

tasks:
  - id: shell
    type: io.kestra.plugin.scripts.shell.Commands
    taskRunner:
      type: io.kestra.plugin.ee.aws.runner.Batch
      accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
      secretKeyId: "{{ secret('AWS_SECRET_KEY_ID') }}"
      region: "{{ vars.region }}"
      computeEnvironmentArn: "{{ vars.computeEnvironmentArn }}"
    commands:
      - echo "Hello World"

yaml
id: container_with_input_files
namespace: company.team

inputs:
  - id: file
    type: FILE

variables:
  region: eu-west-2
  computeEnvironmentArn: "arn:aws:batch:eu-central-1:123456789012:compute-environment/kestraFargateEnvironment"

tasks:
  - id: shell
    type: io.kestra.plugin.scripts.shell.Commands
    inputFiles:
      data.txt: "{{ inputs.file }}"
    outputFiles:
      - out.txt
    containerImage: centos
    taskRunner:
      type: io.kestra.plugin.ee.aws.runner.Batch
      accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
      secretKeyId: "{{ secret('AWS_SECRET_KEY_ID') }}"
      region: "{{ vars.region }}"
      bucket: "{{ vars.bucket }}"
      computeEnvironmentArn: "{{ vars.computeEnvironmentArn }}"
    commands:
      - cp {{ workingDir }}/data.txt {{ workingDir }}/out.txt

yaml
id: aws_batch_runner
namespace: company.team

variables:
  compute_environment_arn: arn:aws:batch:us-east-1:123456789:compute-environment/kestra
  job_queue_arn: arn:aws:batch:us-east-1:123456789:job-queue/kestra
  execution_role_arn: arn:aws:iam::123456789:role/ecsTaskExecutionRole
  task_role_arn: arn:aws:iam::123456789:role/ecsTaskRole

tasks:
  - id: send_data
    type: io.kestra.plugin.scripts.python.Script
    containerImage: ghcr.io/kestra-io/pydata:latest
    taskRunner:
      type: io.kestra.plugin.ee.aws.runner.Batch
      region: us-east-1
      accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
      secretKeyId: "{{ secret('AWS_SECRET_KEY_ID') }}"
      computeEnvironmentArn: "{{ vars.compute_environment_arn }}"
      jobQueueArn: "{{ vars.job_queue_arn}}"
      executionRoleArn: "{{ vars.execution_role_arn }}"
      taskRoleArn: "{{ vars.task_role_arn }}"
      bucket: kestra-us
    script: |
      import platform
      import socket
      import sys

      print("Hello from AWS Batch and kestra!")

      def print_environment_info():
          print(f"Host's network name: {platform.node()}")
          print(f"Python version: {platform.python_version()}")
          print(f"Platform information (instance type): {platform.platform()}")
          print(f"OS/Arch: {sys.platform}/{platform.machine()}")

          try:
              hostname = socket.gethostname()
              ip_address = socket.gethostbyname(hostname)
              print(f"Host IP Address: {ip_address}")
          except socket.error as e:
              print("Unable to obtain IP address.")

      if __name__ == '__main__':
          print_environment_info()

computeEnvironmentArn*string

region*string

type*object

accessKeyIdstring

bucketstring

completionCheckIntervalstring

DefaultPT5S

deletebooleanstring

Defaulttrue

endpointOverridestring

executionRoleArnstring

jobQueueArnstring

resources

Default

{
  "request": {
    "memory": "2048",
    "cpu": "1"
  }
}

io.kestra.plugin.ee.aws.runner.Batch-Resources

request*

io.kestra.plugin.ee.aws.runner.Batch-Resource

cpu*string

memory*string

resumebooleanstring

Defaulttrue

secretKeyIdstring

sessionTokenstring

sidecarResources

io.kestra.plugin.ee.aws.runner.Batch-Resources

request*

io.kestra.plugin.ee.aws.runner.Batch-Resource

cpu*string

memory*string

stsEndpointOverridestring

stsRoleArnstring

stsRoleExternalIdstring

stsRoleSessionDurationstring

DefaultPT15M

stsRoleSessionNamestring

syncWorkingDirectorybooleanstring

Defaultfalse

taskRoleArnstring

versionstring

waitUntilCompletionstring

DefaultPT1H

Run tasks on Google Cloud Batch

Example

yaml
id: new_shell
namespace: company.team

variables:
  projectId: "myproject"
  region: "europe-west2"

tasks:
  - id: shell
    type: io.kestra.plugin.scripts.shell.Commands
    taskRunner:
      type: io.kestra.plugin.ee.gcp.runner.Batch
      projectId: "{{vars.projectId}}"
      region: "{{ vars.region} }"
      serviceAccount: "{{ secret('GOOGLE_SA') }}"
    commands:
      - echo "Hello World"

yaml
id: new_shell_with_file
namespace: company.team

inputs:
  - id: file
    type: FILE

variables:
  projectId: "myProject"
  region: "europe-west2"
  bucket: "myBucket"

tasks:
  - id: shell
    type: io.kestra.plugin.scripts.shell.Commands
    inputFiles:
      data.txt: "{{ inputs.file }}"
    outputFiles:
      - out.txt
    containerImage: centos
    taskRunner:
      type: io.kestra.plugin.ee.gcp.runner.Batch
      projectId: "{{ vars.projectId }}"
      region: "{{ vars.region }}"
      bucket: "{{ vars.bucket }}"
      serviceAccount: "{{ secret('GOOGLE_SA') }}"
    commands:
      - cp {{workingDir}}/data.txt {{workingDir}}/out.txt

yaml
id: gcp_batch_runner
namespace: company.team

tasks:
  - id: scrape_environment_info
    type: io.kestra.plugin.scripts.python.Commands
    containerImage: ghcr.io/kestra-io/pydata:latest
    taskRunner:
      type: io.kestra.plugin.ee.gcp.runner.Batch
      projectId: "{{ secret('GCP_PROJECT_ID') }}"
      region: "europe-west9"
      bucket: "{{ secret('GCS_BUCKET')}}"
      serviceAccount: "{{ secret('GOOGLE_SA') }}"
    commands:
      - python {{ workingDir }}/main.py
    namespaceFiles:
      enabled: true
    outputFiles:
      - environment_info.json
    inputFiles:
      main.py: |
        import platform
        import socket
        import sys
        import json
        from kestra import Kestra

        print("Hello from GCP Batch and kestra!")

        def print_environment_info():
            print(f"Host's network name: {platform.node()}")
            print(f"Python version: {platform.python_version()}")
            print(f"Platform information (instance type): {platform.platform()}")
            print(f"OS/Arch: {sys.platform}/{platform.machine()}")

            env_info = {
                "host": platform.node(),
                "platform": platform.platform(),
                "OS": sys.platform,
                "python_version": platform.python_version(),
            }
            Kestra.outputs(env_info)

            filename = '{{ workingDir }}/environment_info.json'
            with open(filename, 'w') as json_file:
                json.dump(env_info, json_file, indent=4)

        if __name__ == '__main__':
          print_environment_info()

region*string

type*object

Possible Values

io.kestra.plugin.ee.gcp.runner.Batchio.kestra.plugin.gcp.runner.Batch

bucketstring

completionCheckIntervalstring

DefaultPT5S

computeResource

io.kestra.plugin.ee.gcp.runner.Batch-ComputeResource

bootDiskstring

cpustring

memorystring

deletebooleanstring

Defaulttrue

entryPointarray

SubTypestring

impersonatedServiceAccountstring

lifecyclePoliciesarray

io.kestra.plugin.ee.gcp.runner.Batch-LifecyclePolicy

actionstring

Possible Values

ACTION_UNSPECIFIEDRETRY_TASKFAIL_TASKUNRECOGNIZED

actionCondition

io.kestra.plugin.ee.gcp.runner.Batch-LifecyclePolicyAction

exitCodesarray

SubTypeinteger

machineTypestring

Defaulte2-medium

maxCreateJobRetryCountintegerstring

Default2

maxRetryCountinteger

Minimum>= 0

Maximum<= 10

networkInterfacesarray

io.kestra.plugin.ee.gcp.runner.Batch-NetworkInterface

network*string

subnetworkstring

projectIdstring

reservationstring

resumebooleanstring

Defaulttrue

scopesarray

SubTypestring

Default["https://www.googleapis.com/auth/cloud-platform"]

serviceAccountstring

syncWorkingDirectorybooleanstring

Defaultfalse

versionstring

waitForLogIntervalstring

DefaultPT5S

waitUntilCompletionstring

DefaultPT1H

Run tasks on Google Cloud Run

Example

yaml
id: new-shell
namespace: company.team

variables:
  projectId: "projectId"
  region: "europe-west2"

tasks:
  - id: shell
    type: io.kestra.plugin.scripts.shell.Commands
    taskRunner:
      type: io.kestra.plugin.ee.gcp.runner.CloudRun
      projectId: "{{ vars.projectId }}"
      region: "{{ vars.region }}"
      serviceAccount: "{{ secret('GOOGLE_SA') }}"
    commands:
      - echo "Hello World"

yaml
id: new-shell-with-file
namespace: company.team

inputs:
  - id: file
    type: FILE

variables:
  projectId: "projectId"
  bucket: "bucket"
  region: "europe-west2"

tasks:
  - id: shell
    type: io.kestra.plugin.scripts.shell.Commands
    inputFiles:
      data.txt: "{{ inputs.file }}"
    outputFiles:
      - out.txt
    containerImage: centos
    taskRunner:
      type: io.kestra.plugin.ee.gcp.runner.CloudRun
      projectId: "{{ vars.projectId }}"
      region: "{{ vars.region }}"
      bucket: "{{ vars.bucket }}"
      serviceAccount: "{{ secret('GOOGLE_SA') }}"
    commands:
      - cp {{ workingDir }}/data.txt {{ workingDir }}/out.txt

yaml
id: shell-direct-vpc-egress
namespace: company.team

variables:
  projectId: "projectId"
  region: "europe-west1"
  network: "projects/projectId/global/networks/my-vpc"
  subnetwork: "projects/projectId/regions/europe-west1/subnetworks/my-subnet"

tasks:
  - id: shell
    type: io.kestra.plugin.scripts.shell.Commands
    taskRunner:
      type: io.kestra.plugin.ee.gcp.runner.CloudRun
      projectId: "{{ vars.projectId }}"
      region: "{{ vars.region }}"
      network: "{{ vars.network }}"
      subnetwork: "{{ vars.subnetwork }}"
      vpcEgress: ALL_TRAFFIC
      serviceAccount: "{{ secret('GOOGLE_SA') }}"
    commands:
      - echo "Hello from Direct VPC Egress"

region*string

type*object

Possible Values

io.kestra.plugin.ee.gcp.runner.CloudRunio.kestra.plugin.gcp.runner.CloudRun

bucketstring

completionCheckIntervalstring

DefaultPT5S

deletebooleanstring

Defaulttrue

impersonatedServiceAccountstring

maxRetriesintegerstring

Default3

networkstring

projectIdstring

resources

io.kestra.plugin.ee.gcp.runner.CloudRun-ContainerResources

cpustring

memorystring

resumebooleanstring

Defaulttrue

runtimeServiceAccountstring

scopesarray

SubTypestring

Default["https://www.googleapis.com/auth/cloud-platform"]

serviceAccountstring

subnetworkstring

syncWorkingDirectorybooleanstring

versionstring

vpcAccessConnectorstring

vpcEgressstring

Possible Values

VPC_EGRESS_UNSPECIFIEDALL_TRAFFICPRIVATE_RANGES_ONLYUNRECOGNIZED

waitForLogIntervalstring

DefaultPT5S

waitUntilCompletionstring

DefaultPT1H

Run tasks inside Kubernetes pods

Example

yaml
id: new-shell
namespace: company.team

tasks:
  - id: shell
    type: io.kestra.plugin.scripts.shell.Commands
    taskRunner:
      type: io.kestra.plugin.ee.kubernetes.runner.Kubernetes
    commands:
      - echo "Hello World"

yaml
id: new-shell-with-file
namespace: company.team

inputs:
  - id: file
    type: FILE

tasks:
  - id: shell
    type: io.kestra.plugin.scripts.shell.Commands
    inputFiles:
      data.txt: "{{ inputs.file }}"
    outputFiles:
      - out.txt
    containerImage: centos
    taskRunner:
      type: io.kestra.plugin.ee.kubernetes.runner.Kubernetes
    commands:
      - cp {{ workingDir }}/data.txt {{ workingDir }}/out.txt

type*object

Possible Values

io.kestra.plugin.ee.kubernetes.runner.Kubernetesio.kestra.plugin.kubernetes.runner.Kubernetes

config

io.kestra.plugin.ee.kubernetes.models.Connection

apiVersionstring

Defaultv1

caCertDatastring

caCertFilestring

clientCertDatastring

clientCertFilestring

clientKeyAlgostring

DefaultRSA

clientKeyDatastring

clientKeyFilestring

clientKeyPassphrasestring

disableHostnameVerificationbooleanstring

keyStoreFilestring

keyStorePassphrasestring

masterUrlstring

Defaulthttps://kubernetes.default.svc

namespacestring

oauthTokenstring

oauthTokenProvider

OAuth token provider

outputstring

task

passwordstring

trustCertsbooleanstring

trustStoreFilestring

trustStorePassphrasestring

usernamestring

containerDefaultSpecobject

containerSpecobject

deletebooleanstring

Defaulttrue

fileSideCarSpecobject

fileSidecar

Default

{
  "image": "busybox"
}

io.kestra.plugin.ee.kubernetes.runner.SideCar

defaultSpecobject

imagestring

Defaultbusybox

resourcesobject

killed

Defaultfalse

java.util.concurrent.atomic.AtomicBoolean

labelsobject

namespacestring

Defaultdefault

nodeSelectorobject

podSpecobject

pullPolicystring

DefaultALWAYS

Possible Values

IF_NOT_PRESENTALWAYSNEVER

resources

io.kestra.plugin.ee.kubernetes.runner.Kubernetes-Resources

limit

io.kestra.plugin.ee.kubernetes.runner.Kubernetes-Resource

cpustring

memorystring

request

io.kestra.plugin.ee.kubernetes.runner.Kubernetes-Resource

cpustring

memorystring

resumebooleanstring

Defaulttrue

serviceAccountNamestring

syncWorkingDirectorybooleanstring

Defaultfalse

versionstring

waitForLogsstring

DefaultPT30S

waitUntilCompletionstring

DefaultPT1H

waitUntilRunningstring

DefaultPT10M

Outputs

exitCode integer

Default0

outputFiles object

SubTypestring

taskRunner

Definitions

io.kestra.core.models.tasks.runners.TaskRunnerDetailResult

vars object

Ingest AWS Resource Metadata into Postgres Using CloudQuery for Security and Governance Analysis

Data Ingestion Pipeline, Sync Hacker News Data to CSV Files Using CloudQuery

Weaviate

Tasks that manage and query vectors in Weaviate.

DataAI

Apache Pinot

Tasks that connect to Apache Pinot via JDBC to run queries and loads.

Data

DataHub

Tasks that run DataHub CLI ingestions and interact with DataHub metadata.

Data

CloudQueryCLI

Run CloudQuery CLI commands

Create automations with Cloudquery CloudQueryCLI

Ingest AWS Resource Metadata into Postgres Using CloudQuery for Security and Governance Analysis

Data Ingestion Pipeline, Sync Hacker News Data to CSV Files Using CloudQuery

More Plugins in this Category

Weaviate

Apache Pinot

DataHub

1.1.2

CloudQueryCLI Run CloudQuery CLI commands

Create automations with Cloudquery CloudQueryCLI

Ingest AWS Resource Metadata into Postgres Using CloudQuery for Security and Governance Analysis

Data Ingestion Pipeline, Sync Hacker News Data to CSV Files Using CloudQuery

More Plugins in this Category

Weaviate

Apache Pinot

DataHub

1.1.2

CloudQueryCLI

Run CloudQuery CLI commands