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.2.0.tar.gz (30.7 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.2.0-py3-none-any.whl (23.2 kB view details)

Uploaded Python 3

File details

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

File metadata

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

File hashes

Hashes for rail_engine_ingest-0.2.0.tar.gz
Algorithm Hash digest
SHA256 0220fd11d2e4a0530c51968e720dd4fdbaccbea71c0788799c6edc321174a52a
MD5 37e8e510fc56dc611b045c7b63864568
BLAKE2b-256 c2ee504821101dfcdb5980ab41367c49924b9a53a7371fee55beb274b44a7bcf

See more details on using hashes here.

File details

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

File metadata

File hashes

Hashes for rail_engine_ingest-0.2.0-py3-none-any.whl
Algorithm Hash digest
SHA256 b55cd019940fa081a1c48ea4774a40c73d8f4d2c0b7b53eb5cace92edb3271c1
MD5 4e9df4c80e267fa24346dea527307695
BLAKE2b-256 29b1dc3b7673ad47adbc8cfdfff0b2f9da55670aec0f14edfe97549b9adf5c00

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