Getting Started

import { KadoaClient } from '@kadoa/node-sdk';

const client = new KadoaClient({
  apiKey: 'YOUR_API_KEY'
});

const result = await client.extraction.run({
  urls: ["https://sandbox.kadoa.com/ecommerce"],
  name: "My First Extraction",
  limit: 10,
});

console.log(result.data);

from kadoa_sdk import ExtractionOptions, KadoaClient, KadoaClientConfig

client = KadoaClient(KadoaClientConfig(api_key="YOUR_API_KEY"))

result = client.extraction.run(
    ExtractionOptions(
        urls=["https://sandbox.kadoa.com/ecommerce"],
        name="My First Extraction",
        limit=10,
    )
)

print(result.data)

kadoa create "Extract product names and prices" \
  --url https://sandbox.kadoa.com/ecommerce \
  --name "My First Extraction"

> "Extract product names and prices from https://sandbox.kadoa.com/ecommerce"

# 1. Create workflow with schema definition
curl -X POST https://api.kadoa.com/v4/workflows \
  -H "x-api-key: YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "urls": ["https://sandbox.kadoa.com/ecommerce"],
    "name": "My First Extraction",
    "entity": "Product",
    "fields": [
      {
        "name": "title",
        "dataType": "STRING",
        "description": "Product name"
      },
      {
        "name": "price",
        "dataType": "MONEY",
        "description": "Product price"
      }
    ]
  }'

# Response:
# {
#   "success": true,
#   "workflowId": "507f1f77bcf86cd799439011"
# }

# 2. Check workflow status
curl -X GET https://api.kadoa.com/v4/workflows/507f1f77bcf86cd799439011 \
  -H "x-api-key: YOUR_API_KEY"

# 3. Get the data (once extraction is complete)
curl -X GET https://api.kadoa.com/v4/workflows/507f1f77bcf86cd799439011/data \
  -H "x-api-key: YOUR_API_KEY"

const workflow = await client
  .extract({
    urls: ["https://sandbox.kadoa.com/ecommerce"],
    name: "Product Monitor",
    extraction: (builder) =>
      builder
        .entity("Product")
        .field("name", "Product name", "STRING", {
          example: "MacBook Pro",
        })
        .field("price", "Price in USD", "MONEY")
        .field("inStock", "Is available", "BOOLEAN"),
  })
  .create();

const result = await workflow.run({ limit: 10 });
const response = await result.fetchData({});
console.log(response.data);

from kadoa_sdk import (
    ExtractOptions,
    FieldOptions,
    KadoaClient,
    KadoaClientConfig,
    RunWorkflowOptions,
)

client = KadoaClient(KadoaClientConfig(api_key="YOUR_API_KEY"))

extract_options = ExtractOptions(
    urls=["https://sandbox.kadoa.com/ecommerce"],
    name="Product Monitor",
    extraction=lambda builder: builder.entity("Product")
    .field("name", "Product name", "STRING", FieldOptions(example="MacBook Pro"))
    .field("price", "Price in USD", "MONEY")
    .field("inStock", "Is available", "BOOLEAN"),
)

workflow = client.extract(extract_options).create()
print(f"Workflow created: {workflow.workflow_id}")

result = workflow.run(RunWorkflowOptions(limit=10))
response = result.fetch_data({})
print(response.data)

kadoa create "Extract product name, price, and availability" \
  --url https://sandbox.kadoa.com/ecommerce \
  --name "Product Monitor" \
  --entity "Product"

> "Extract product name, price in USD, and availability from https://sandbox.kadoa.com/ecommerce"

// POST https://api.kadoa.com/v4/workflows
{
  "urls": ["https://sandbox.kadoa.com/ecommerce"],
  "name": "Product Monitor",
  "entity": "Product",
  "fields": [
    {
      "name": "name",
      "dataType": "STRING",
      "description": "Product name"
    },
    {
      "name": "price",
      "dataType": "MONEY",
      "description": "Price in USD"
    },
    {
      "name": "inStock",
      "dataType": "BOOLEAN",
      "description": "Is available"
    }
  ]
}