Skip to main content

Python SDK for Railtown AI Railengine - Ingestion

Project description

Railengine Ingestion SDK

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

Overview

The rail-engine-ingest package provides a Pythonic interface for publishing data to Railengine. 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 Railengine, 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.1.tar.gz (23.2 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.1-py3-none-any.whl (26.8 kB view details)

Uploaded Python 3

File details

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

File metadata

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

File hashes

Hashes for rail_engine_ingest-0.2.1.tar.gz
Algorithm Hash digest
SHA256 e728641113ce64da30c72f5e6f3ec306eb20e3bc2a64c80263b7c801014d923a
MD5 c40fd839ff6083553b71315a548d4a72
BLAKE2b-256 96c5ff77b367bb2e5401867a445cf0063e6616425dd640bdfe8f4c101ffcf855

See more details on using hashes here.

File details

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

File metadata

File hashes

Hashes for rail_engine_ingest-0.2.1-py3-none-any.whl
Algorithm Hash digest
SHA256 c063f8321648cab0c687cc3c37efecfdf53a98b9e2a409b9d4eb9265d3d9a126
MD5 124649503532e793901586dafc55d0be
BLAKE2b-256 66f4cb5865023f6b5766dd7d4064764397a59815e08de544304f24ba15f766c2

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