from atomscale.streaming import TimeseriesStreamer

streamer = TimeseriesStreamer(api_key="YOUR_API_KEY", points_per_chunk=100)
data_id = streamer.initialize(
    stream_name="MBE Run 2024-01-15 Thickness Monitor",
    physical_sample="GaN-001",
    project_id="d290f1ee-6c54-4b01-90e6-d701748f0851",
)

import requests

response = requests.post(
    "https://api.atomscale.ai/metrology/stream/initialize",
    headers={
        "X-API-KEY": "YOUR_API_KEY",
        "Content-Type": "application/json"
    },
    json={
        "stream_name": "MBE Run 2024-01-15 Thickness Monitor",
        "points_per_chunk": 100,
        "project_id": "d290f1ee-6c54-4b01-90e6-d701748f0851",
        "physical_sample_id": "a1b2c3d4-5678-90ab-cdef-1234567890ab"
    }
)
result = response.json()
data_id = result["data_id"]

curl -X POST "https://api.atomscale.ai/metrology/stream/initialize" \
  -H "X-API-KEY: YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "stream_name": "MBE Run 2024-01-15 Thickness Monitor",
    "points_per_chunk": 100,
    "project_id": "d290f1ee-6c54-4b01-90e6-d701748f0851",
    "physical_sample_id": "a1b2c3d4-5678-90ab-cdef-1234567890ab"
  }'

{
  "data_id": "d290f1ee-6c54-4b01-90e6-d701748f0851",
  "processed_data_id": "e3a1b2c3-4567-89ab-cdef-234567890abc"
}