OpenInterest Lens SDK

Real-time futures market structure API — OI + COT + term structure as developer-ready signals.

Install

pip install openinterest-lens

For WebSocket streaming support:

pip install openinterest-lens[ws]

Quick Start

from openinterest_lens import OpenInterestLensClient

client = OpenInterestLensClient(
    api_key="oil_sk_live_your_key_here",
    base_url="https://api.openinterestlens.com"  # or http://localhost:8000 for local
)

# Get positioning signals for S&P 500 E-mini
signal = client.get_signals("ES")
print(f"Smart Money Direction: {signal.data.direction}")
print(f"Conviction: {signal.data.conviction}")

# Get term structure
ts = client.get_term_structure("ES")

# Get COT data
cot = client.get_cot("ES")

# List available contracts
contracts = client.get_contracts()

client.close()

Async Client

import asyncio
from openinterest_lens import AsyncOpenInterestLensClient

async def main():
    async with AsyncOpenInterestLensClient(api_key="...") as client:
        signal = await client.get_signals("ES")
        print(signal.data.direction)

asyncio.run(main())

Builder Pattern

from openinterest_lens import ClientBuilder

client = (
    ClientBuilder()
    .base_url("https://api.openinterestlens.com")
    .api_key("oil_sk_live_...")
    .timeout(60)
    .max_retries(5)
    .build()
)

WebSocket Streaming

import asyncio
from openinterest_lens import AsyncSignalStream

async def stream():
    stream = AsyncSignalStream(
        api_key="oil_sk_live_...",
        contracts=["ES", "NQ", "CL"],
    )
    async for event in stream:
        print(f"{event['contract']}: {event['signal']['direction']}")

asyncio.run(stream())

API Endpoints

Tiers

License

MIT