Ingest Context

import json

with open("/path/to/policy.pdf", "rb") as f1, open("/path/to/runbook.pdf", "rb") as f2:
    result = client.context.ingest(
        type="knowledge",
        database="acme_corp",
        documents=[
            ("policy.pdf", f1, "application/pdf"),
            ("runbook.pdf", f2, "application/pdf"),
        ],
        document_metadata=json.dumps([
            {"id": "policy_main", "metadata": {"department": "legal"}},
            {"id": "runbook_deploy", "metadata": {"department": "ops"}},
        ]),
    )

const result = await client.context.ingest({
  type: "knowledge",
  database: "acme_corp",
  documents: [
    { path: "/path/to/policy.pdf", filename: "policy.pdf", contentType: "application/pdf" },
    { path: "/path/to/runbook.pdf", filename: "runbook.pdf", contentType: "application/pdf" },
  ],
  documentMetadata: JSON.stringify([
    { id: "policy_main", metadata: { department: "legal" } },
    { id: "runbook_deploy", metadata: { department: "ops" } },
  ]),
});

curl -X POST 'https://api.hydradb.com/context/ingest' \
  -H "Authorization: Bearer <your_api_key>" \
  -H "API-Version: 2" \
  -F "type=knowledge" \
  -F "database=acme_corp" \
  -F "documents=@/path/to/policy.pdf" \
  -F "documents=@/path/to/runbook.pdf" \
  -F 'document_metadata=[
    { "id": "policy_main", "metadata": { "department": "legal" } },
    { "id": "runbook_deploy", "metadata": { "department": "ops" } }
  ]'

import json

client.context.ingest(
    type="knowledge",
    database="acme_corp",
    collection="team_docs",
    app_knowledge=json.dumps([
        {
            "id": "slack_thread_001",
            "title": "Pricing discussion",
            "kind": "message",
            "provider": "slack",
            "external_id": "1716213600.000100",
            "fields": {"kind": "message", "body": "We agreed on three tiers...", "author": "alice"},
            "metadata": {"channel": "product"},
        }
    ]),
)

await client.context.ingest({
  type: "knowledge",
  database: "acme_corp",
  collection: "team_docs",
  appKnowledge: JSON.stringify([
    {
      id: "slack_thread_001",
      title: "Pricing discussion",
      kind: "message",
      provider: "slack",
      external_id: "1716213600.000100",
      fields: { kind: "message", body: "We agreed on three tiers...", author: "alice" },
      metadata: { channel: "product" },
    },
  ]),
});

curl -X POST 'https://api.hydradb.com/context/ingest' \
  -H "Authorization: Bearer <your_api_key>" \
  -H "API-Version: 2" \
  -F "type=knowledge" \
  -F "database=acme_corp" \
  -F "collection=team_docs" \
  -F 'app_knowledge=[
    {
      "id": "slack_thread_001",
      "title": "Pricing discussion",
      "kind": "message",
      "provider": "slack",
      "external_id": "1716213600.000100",
      "fields": { "kind": "message", "body": "We agreed on three tiers...", "author": "alice" },
      "metadata": { "channel": "product" }
    }
  ]'

import json

client.context.ingest(
    type="memory",
    database="acme_corp",
    collection="user_alex",
    memories=json.dumps([
        {
            "text": "Prefers dark mode and short answers.",
            "infer": True,
            "user_name": "Alex",
        }
    ]),
)

await client.context.ingest({
  type: "memory",
  database: "acme_corp",
  collection: "user_alex",
  memories: JSON.stringify([
    {
      text: "Prefers dark mode and short answers.",
      infer: true,
      user_name: "Alex",
    },
  ]),
});

curl -X POST 'https://api.hydradb.com/context/ingest' \
  -H "Authorization: Bearer <your_api_key>" \
  -H "API-Version: 2" \
  -F "type=memory" \
  -F "database=acme_corp" \
  -F "collection=user_alex" \
  -F 'memories=[
    {
      "text": "Prefers dark mode and short answers.",
      "infer": true,
      "user_name": "Alex"
    }
  ]'

import json

client.context.ingest(
    type="memory",
    database="acme_corp",
    collection="user_alex",
    memories=json.dumps([
        {
            "title": "Support conversation about refunds",
            "user_assistant_pairs": [
                {"user": "Can I get a refund?", "assistant": "Refunds are available within 30 days."},
            ],
            "infer": False,
        }
    ]),
)

await client.context.ingest({
  type: "memory",
  database: "acme_corp",
  collection: "user_alex",
  memories: JSON.stringify([
    {
      title: "Support conversation about refunds",
      user_assistant_pairs: [
        { user: "Can I get a refund?", assistant: "Refunds are available within 30 days." },
      ],
      infer: false,
    },
  ]),
});

curl -X POST 'https://api.hydradb.com/context/ingest' \
  -H "Authorization: Bearer <your_api_key>" \
  -H "API-Version: 2" \
  -F "type=memory" \
  -F "database=acme_corp" \
  -F "collection=user_alex" \
  -F 'memories=[
    {
      "title": "Support conversation about refunds",
      "user_assistant_pairs": [
        { "user": "Can I get a refund?", "assistant": "Refunds are available within 30 days." }
      ],
      "infer": false
    }
  ]'

curl -X POST 'https://api.hydradb.com/context/ingest' \
  -H "Authorization: Bearer <your_api_key>" \
  -H "API-Version: 2" \
  -F "type=knowledge" \
  -F "database=acme_corp" \
  -F "documents=@/path/to/policy.pdf" \
  -F 'document_metadata=[{ "id": "billing-policy-doc" }]' \
  -F 'graph_payload={
    "billing-policy-doc": {
      "entities": {
        "alice":   { "name": "Alice Carter",  "type": "PERSON", "namespace": "employees" },
        "billing": { "name": "Billing Policy", "type": "POLICY", "namespace": "policies" }
      },
      "relations": [
        { "source": "alice", "target": "billing", "predicate": "OWNS",
          "context": "Alice Carter owns the billing policy." }
      ]
    }
  }'

import json

with open("/path/to/policy.pdf", "rb") as f:
    client.context.ingest(
        type="knowledge",
        database="acme_corp",
        documents=[("policy.pdf", f, "application/pdf")],
        document_metadata=json.dumps([{"id": "billing-policy-doc"}]),
        graph_payload=json.dumps({
            "billing-policy-doc": {
                "entities": {
                    "alice":   {"name": "Alice Carter",  "type": "PERSON", "namespace": "employees"},
                    "billing": {"name": "Billing Policy", "type": "POLICY", "namespace": "policies"},
                },
                "relations": [
                    {"source": "alice", "target": "billing", "predicate": "OWNS",
                     "context": "Alice Carter owns the billing policy."},
                ],
            }
        }),
    )

await client.context.ingest({
  type: "knowledge",
  database: "acme_corp",
  documents: [{ path: "/path/to/policy.pdf", filename: "policy.pdf", contentType: "application/pdf" }],
  documentMetadata: JSON.stringify([{ id: "billing-policy-doc" }]),
  graphPayload: JSON.stringify({
    "billing-policy-doc": {
      entities: {
        alice:   { name: "Alice Carter",  type: "PERSON", namespace: "employees" },
        billing: { name: "Billing Policy", type: "POLICY", namespace: "policies" },
      },
      relations: [
        { source: "alice", target: "billing", predicate: "OWNS",
          context: "Alice Carter owns the billing policy." },
      ],
    },
  }),
});