1
from meshapi import MeshAPI, ChatCompletionParams, ChatMessage
2
3
# Initialize the client with your data-plane API key
4
client = MeshAPI(base_url="https://api.meshapi.ai", token="rsk_...")
5
6
# Non-streaming request
7
resp = client.chat.completions.create(
8
    ChatCompletionParams(
9
        model="openai/gpt-4o-mini",
10
        messages=[ChatMessage(role="user", content="What is 2+2?")],
11
    )
12
)
13
print(resp.choices[0].message.content)
14
15
# Streaming request
16
for chunk in client.chat.completions.stream(
17
    ChatCompletionParams(
18
        model="openai/gpt-4o-mini",
19
        messages=[ChatMessage(role="user", content="Count to 5.")],
20
    )
21
):
22
    if chunk.choices and chunk.choices[0].delta:
23
        print(chunk.choices[0].delta.content, end="", flush=True)

1
import asyncio
2
from meshapi import AsyncMeshAPI, ChatCompletionParams, ChatMessage
3
4
async def main():
5
    async with AsyncMeshAPI(base_url="https://api.meshapi.ai", token="rsk_...") as client:
6
        resp = await client.chat.completions.create(
7
            ChatCompletionParams(
8
                model="openai/gpt-4o-mini",
9
                messages=[ChatMessage(role="user", content="Hello!")],
10
            )
11
        )
12
        print(resp.choices[0].message.content)
13
14
asyncio.run(main())

1
from meshapi import MeshAPIError
2
3
try:
4
    resp = client.chat.completions.create(...)
5
except MeshAPIError as e:
6
    print(e.status)               # HTTP status code
7
    print(e.error_code)           # "rate_limit_exceeded", "unauthorized", etc.
8
    print(e.request_id)           # Traceable request ID
9
    print(e.retry_after_seconds)  # Present on 429 errors