feat: update python SDK

api/client/javascript/src/client/schemas.ts

@@ -10770,7 +10770,11 @@ export interface components {
        * Price
        * @description The price of the rate card.
        *     When null, the feature or service is free.
-       * @example {}
+       * @example {
+       *       "type": "flat",
+       *       "amount": "100",
+       *       "paymentTerm": "in_arrears"
+       *     }
        */
       price: components['schemas']['RateCardUsageBasedPrice'] | null
       /**

api/client/python/.gitattributes

@@ -1 +1 @@
-src/**/* linguist-generated=true
+openmeter/**/* linguist-generated=true

api/client/python/.gitignore

@@ -1,11 +1,19 @@
 # python
-.python-version
+# Packaging
+*.egg-info/
+*.egg
+*.eggs/
+dist/
+build/
+CHANGELOG.md
+
+# Python cache
 __pycache__/
 *.pyc
-build
-dist
-pydo.egg-info
-.venv
+*.pyo
+*.pyd
 
-# generate
-openapi.yaml
+# Virtual envs
+.python-version
+.venv/
+venv/

api/client/python/MANIFEST.in

@@ -0,0 +1,5 @@
+include *.md
+include LICENSE
+include openmeter/py.typed
+recursive-include tests *.py
+recursive-include samples *.py *.md

api/client/python/README.md

@@ -1,10 +1,12 @@
 # OpenMeter Python SDK
 
-[https://pypi.org/project/openmeter](On PyPI)
+[On PyPI](https://pypi.org/project/openmeter)
+
+This package is generated by `@typespec/http-client-python` with Typespec.
 
 ## Prerequisites
 
-Python version: >= 3.9
+- Python 3.9 or later is required to use this package.
 
 ## Install
 
@@ -14,54 +16,127 @@ Python version: >= 3.9
 pip install openmeter
 ```
 
-## Quickstart
+## Examples
+
+### Setup
 
-The client can be initialized with `openmeter.Client()`:
+#### Synchronous Client
 
 ```python
-from os import environ
 from openmeter import Client
 
-ENDPOINT = environ.get("OPENMETER_ENDPOINT") or "http://localhost:8888"
+client = Client(
+    endpoint="https://openmeter.cloud",
+    token="your-api-token",
+)
+```
+
+#### Async Client
+
+```python
+from openmeter.aio import Client
 
-# it's recommended to also set the Accept header at the client level
 client = Client(
-    endpoint=ENDPOINT,
-    headers={"Accept": "application/json"},
+    endpoint="https://openmeter.cloud",
+    token="your-api-token",
 )
 ```
 
-**Async** client can be initialized by importing the `Client` from `openmeter.aio`.
+### Ingest an Event
 
-Ingest events:
+#### Synchronous
 
 ```python
-from cloudevents.http import CloudEvent
-from cloudevents.conversion import to_dict
-
-event = CloudEvent(
-    attributes={
-        "type": "tokens",
-        "source": "openmeter-python",
-        "subject": "user-id",
-    },
+import datetime
+import uuid
+
+from openmeter.models import Event
+
+# Create an Event instance (following CloudEvents specification)
+event = Event(
+    id=str(uuid.uuid4()),
+    source="my-app",
+    specversion="1.0",
+    type="prompt",
+    subject="customer-1",
+    time=datetime.datetime.now(datetime.timezone.utc),
     data={
-        "prompt_tokens": 5,
-        "completion_tokens": 10,
-        "total_tokens": 15,
-        "model": "gpt-3.5-turbo",
+        "tokens": 100,
+        "model": "gpt-4o",
+        "type": "input",
     },
 )
 
-resp = client.ingest_events(to_dict(event))
+# Ingest the event
+client.events.ingest_event(event)
+```
+
+#### Async
+
+```python
+import datetime
+import uuid
+import asyncio
+
+from openmeter.aio import Client
+from openmeter.models import Event
+
+async def main():
+    async with Client(
+        endpoint="https://openmeter.cloud",
+        token="your-api-token",
+    ) as client:
+        # Create an Event instance (following CloudEvents specification)
+        event = Event(
+            id=str(uuid.uuid4()),
+            source="my-app",
+            specversion="1.0",
+            type="prompt",
+            subject="customer-1",
+            time=datetime.datetime.now(datetime.timezone.utc),
+            data={
+                "tokens": 100,
+                "model": "gpt-4o",
+                "type": "input",
+            },
+        )
+
+        # Ingest the event
+        await client.events.ingest_event(event)
+
+asyncio.run(main())
 ```
 
-## Publish
+### Query Meter
 
-Update version number in `pyproject.toml`.
-Run the following commands:
+#### Synchronous
 
-```sh
-poetry config pypi-token.pypi {your_pypi_api_token}
-poetry publish --build
+```python
+from openmeter.models import MeterQueryResult
+
+# Query total values
+r: MeterQueryResult = client.meters.query_json(meter_id_or_slug="tokens_total")
+print("Query total values:", r.data[0].value)
+```
+
+#### Async
+
+```python
+import asyncio
+
+from openmeter.aio import Client
+from openmeter.models import MeterQueryResult
+
+async def main():
+    async with Client(
+        endpoint="https://openmeter.cloud",
+        token="your-api-token",
+    ) as client:
+        # Query total values
+        r: MeterQueryResult = await client.meters.query_json(
+            meter_id_or_slug="tokens_total"
+        )
+        print("Query total values:", r.data[0].value)
+
+asyncio.run(main())
 ```

api/client/python/examples/README.md

@@ -0,0 +1,15 @@
+# Examples
+
+Install dependencies
+
+```sh
+poetry install
+```
+
+Run examples
+
+```sh
+OPENMETER_ENDPOINT=https://openmeter.cloud \
+OPENMETER_TOKEN=om_xxx \
+poetry run python ./sync/ingest.py
+```

api/client/python/examples/async/customer.py

@@ -0,0 +1,72 @@
+from os import environ
+from typing import Optional
+import asyncio
+
+from openmeter.aio import Client
+from openmeter.models import (
+    CustomerCreate,
+    CustomerReplaceUpdate,
+    CustomerUsageAttribution,
+)
+from corehttp.exceptions import HttpResponseError
+
+ENDPOINT: str = environ.get("OPENMETER_ENDPOINT") or "https://openmeter.cloud"
+token: Optional[str] = environ.get("OPENMETER_TOKEN")
+customer_key: str = environ.get("OPENMETER_CUSTOMER_KEY") or "acme-corp-1"
+subject_key: str = environ.get("OPENMETER_SUBJECT_KEY") or "acme-user-1"
+
+
+async def main() -> None:
+    async with Client(
+        endpoint=ENDPOINT,
+        token=token,
+    ) as client:
+        try:
+            # Create a customer
+            customer_create = CustomerCreate(
+                name="Acme Corporation",
+                key=customer_key,
+                description="A demo customer for testing",
+                primary_email="contact@acme-corp.example.com",
+                currency="EUR",
+                usage_attribution=CustomerUsageAttribution(subject_keys=[subject_key]),
+                metadata={
+                    "industry": "technology",
+                },
+            )
+
+            created_customer = await client.customer.customers.create(customer_create)
+            print(f"Customer created successfully with ID: {created_customer.id}")
+            print(f"Customer name: {created_customer.name}")
+            print(f"Customer key: {created_customer.key}")
+
+            # Get the customer by ID or key
+            customer = await client.customer.customers.get(created_customer.id)
+            print(f"\nRetrieved customer: {customer.name}")
+            print(f"Primary email: {customer.primary_email}")
+            print(f"Currency: {customer.currency}")
+
+            # Update the customer
+            customer_update = CustomerReplaceUpdate(
+                name="Acme Corporation Ltd.",
+                key=customer_key,
+                description="Updated demo customer",
+                primary_email="info@acme-corp.example.com",
+                currency="USD",
+                usage_attribution=CustomerUsageAttribution(subject_keys=[subject_key]),
+                metadata={
+                    "industry": "technology",
+                },
+            )
+
+            updated_customer = await client.customer.customers.update(created_customer.id, customer_update)
+            print(f"\nCustomer updated successfully")
+            print(f"Updated name: {updated_customer.name}")
+            print(f"Updated email: {updated_customer.primary_email}")
+            print(f"Updated currency: {updated_customer.currency}")
+
+        except HttpResponseError as e:
+            print(f"Error: {e}")
+
+
+asyncio.run(main())