Skip to main content

Python SDK for Railtown AI Rail Engine - Ingestion

Project description

Rail Engine Ingestion SDK

Python SDK for ingesting data into Railtown AI Rail Engine - handles embeddings, storage, indexing, and webhook publishing.

Overview

The rail-engine-ingest package provides a Pythonic interface for publishing data to Rail Engine. It supports async/await patterns, Pydantic model validation, and familiar configuration patterns.

Installation

uv pip install rail-engine-ingest

Quick Start

# Copy your ENGINE_TOKEN from https://cndr.railtown.ai Project Settings

import asyncio
import os
from railtown.engine.ingest import RailengineIngest
import base64
import json

engine_token = os.getenv("ENGINE_TOKEN")

async def main():
    # Initialize client
    async with RailengineIngest(engine_token=engine_token) as client:
        # Ingest data
        data = {
            "name": "Chicken Shawarma",
            "meal": "lunch",
            "calories": 95
        }
        response = await client.upsert(data)
        print(f"Status: {response.status_code}")

asyncio.run(main())

Configuration

Environment Variable

  • ENGINE_TOKEN - Base64-encoded JSON string containing ingestion credentials

Constructor Parameters

  • engine_token (optional) - ENGINE_TOKEN string (if not provided, reads from env)
  • model (optional) - Pydantic model type for validating ingested data

Features

  • Single upsert() method - Unified interface for ingesting data
  • Multiple data formats - Accepts Pydantic models, dictionaries, or JSON strings
  • Model validation - Optional Pydantic model validation
  • Direct JSON payload - Sends data directly as JSON to the ingestion endpoint
  • Webhook handler - get_webhook_handler() returns a payload parser when the client is constructed with model=
  • Async/await support - Built for modern async Python applications

Error Handling

The SDK provides custom exception classes:

  • RailtownError - Base exception
  • RailtownBadRequestError - 400 Bad Request
  • RailtownUnauthorizedError - 401 Unauthorized
  • RailtownNotFoundError - 404 Not Found
  • RailtownConflictError - 409 Conflict
  • RailtownServerError - 5xx Server errors

Exceptions are raised on errors.

Requirements

  • uv
  • Python 3.10+
  • httpx >= 0.24.0
  • pydantic >= 1.10.0

Related package

For retrieving and searching data from Rail Engine, install and use rail-engine.

License

MIT

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

rail_engine_ingest-0.1.8.tar.gz (30.4 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

rail_engine_ingest-0.1.8-py3-none-any.whl (23.3 kB view details)

Uploaded Python 3

File details

Details for the file rail_engine_ingest-0.1.8.tar.gz.

File metadata

  • Download URL: rail_engine_ingest-0.1.8.tar.gz
  • Upload date:
  • Size: 30.4 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: uv/0.8.22

File hashes

Hashes for rail_engine_ingest-0.1.8.tar.gz
Algorithm Hash digest
SHA256 74f3622f2df2e452218b689904bc8188b52cd367ce8a224bb944e687292d8141
MD5 e192bdb3817dfa50b556211b256cc75d
BLAKE2b-256 22704d07f3910f56aae692bcbb85e76d2db4ebd04ded1a573a60b7114fc32036

See more details on using hashes here.

File details

Details for the file rail_engine_ingest-0.1.8-py3-none-any.whl.

File metadata

File hashes

Hashes for rail_engine_ingest-0.1.8-py3-none-any.whl
Algorithm Hash digest
SHA256 1051853acc1b96ff15d69cccad85f5c388868840da9c05aef9beb16a51a64808
MD5 409fa03c2dcab8c3a6a5cf756feaeba2
BLAKE2b-256 cb555567186551bb67c86f2c406625e7ca217cccaa44ab462c0a7eb5c369e798

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page