Skip to main content

Multi-modal capture orchestration framework with precision sync for Physical AI data collection

Project description

syncfield-python

Multi-modal capture orchestration for Physical AI. Drive cameras, IMUs, and custom sensors through one atomic recording lifecycle, get crash-safe per-stream timestamp logs, and produce episode directories the SyncField sync service aligns to sub-frame precision.

Docs: opengraphlabs.com/docs

Install

pip install syncfield

The default install ships UVCWebcamStream and the browser viewer. Optional adapters are opt-in:

Need Install
USB / Continuity cameras + viewer + audio chirps pip install syncfield
BLE IMU sensors pip install "syncfield[ble]"
Off-host cameras (Quest, Insta360 Go3S) pip install "syncfield[camera]"
OAK-D depth cameras pip install "syncfield[oak]"
Multi-host leader/follower over mDNS pip install "syncfield[multihost]"
Everything pip install "syncfield[all]"

Importing an adapter whose extra is missing raises ImportError with the install hint.

Minimal example

from pathlib import Path

import syncfield as sf
import syncfield.viewer
from syncfield.adapters import UVCWebcamStream

session = sf.SessionOrchestrator(
    host_id="mac_studio",
    output_dir=Path(__file__).parent / "output",
)
out = session.output_dir

session.add(UVCWebcamStream("mac_webcam", device_index=0, output_dir=out))
session.add(UVCWebcamStream("iphone",     device_index=1, output_dir=out))

syncfield.viewer.launch(session)
python record.py

Per-episode output under ./output/<episode_id>/:

sync_point.json                 # Time anchor + chirp metadata
manifest.json                   # Per-stream metadata
session_log.jsonl               # Crash-safe timeline
mac_webcam.mp4
mac_webcam.timestamps.jsonl
iphone.mp4
iphone.timestamps.jsonl

That directory is the sync service's input format. No conversion step.

Lifecycle

add() → connect() → start() → RECORDING → stop() → finalized episode dir
                      |                      |
                      └── start chirp        └── stop chirp

Each device is wrapped in a Stream adapter with a fixed SPI: prepare → connect → start_recording → stop_recording → disconnect. The orchestrator drives all adapters through one state machine. If one stream fails during connect, it is marked failed and cleaned up while the remaining streams can still record; if every stream fails, the session returns to idle. Start and stop chirps become the cross-host alignment anchor in multi-host mode.

Shipped adapters: UVCWebcamStream, BLEImuGenericStream, OakCameraStream, MetaQuestCameraStream, MetaQuestHandStream, Go3SStream (Insta360), OgloTactileStream, HostAudioStream, JSONLFileStream, PollingSensorStream, PushSensorStream.

Multi-host

pip install "syncfield[multihost]"
# Leader
python examples/multihost_lab/leader.py

# Every other host
python examples/multihost_lab/follower.py

After the leader's stop(), session.collect_from_followers() pulls every follower's files into one canonical tree. See examples/multihost_lab/.

Documentation

Guide Covers
Quick Start iPhone+Mac and Quest+IMUs recipes
Python SDK SessionOrchestrator lifecycle, Stream SPI
Device Adapters Per-adapter constructors and authoring
Web Viewer Record / Review modes, passive embedding
Multi-Host Sessions Leader/follower, mDNS, cross-host alignment
Device Discovery Auto-enumerate attached hardware
Concepts Pipeline, hosts, streams, acoustic anchor
API Reference Sync service REST API

Output format

sync_point.json

{
  "sdk_version": "0.4.0",
  "monotonic_ns": 1234567890123456789,
  "wall_clock_ns": 1709890101000000000,
  "host_id": "mac_studio",
  "timestamp_ms": 1709890101000,
  "iso_datetime": "2024-03-08T12:00:01.000000"
}

Optional fields: chirp_start_ns / chirp_stop_ns / chirp_spec (when a chirp was played), session_id / role (multi-host).

{stream_id}.timestamps.jsonl

One JSON object per line.

{"frame_number":0,"capture_ns":1234567890123456789,"clock_source":"host_monotonic","clock_domain":"mac_studio","device_timestamp_ns":987654321000}
{"frame_number":1,"capture_ns":1234567890156789012,"clock_source":"host_monotonic","clock_domain":"mac_studio","device_timestamp_ns":987687654000}
Field Type Meaning
frame_number int 0-based sequential index
capture_ns int Monotonic ns at data arrival
clock_source string Typically "host_monotonic"
clock_domain string Matches host_id for host-clocked streams
device_timestamp_ns int Optional device-clock timestamp, kept separate from host capture_ns

capture_ns is monotonically non-decreasing within a stream. clock_domain is identical across host-clocked streams on the same host. Device-clock timestamps, when an adapter exposes them, are persisted as top-level device_timestamp_ns so channels stays sensor-only. File name must be the literal {stream_id}.timestamps.jsonl.

{stream_id}.jsonl (sensor data)

Each line carries a sample plus a channels payload. Leaf values must be numeric. Nested dicts and lists are flattened to dot-notation keys (joints.wrist.0) at sync time.

{"frame_number":0,"capture_ns":1234567890123456789,"clock_source":"host_monotonic","clock_domain":"mac_studio","device_timestamp_ns":987654321000,"channels":{"accel_x":0.12,"accel_y":-9.8,"accel_z":0.05}}

manifest.json

Written by stop(). Maps every stream to its kind, capabilities, and produced files.

{
  "sdk_version": "0.4.0",
  "host_id": "mac_studio",
  "streams": {
    "mac_webcam": {
      "kind": "video",
      "capabilities": {"provides_audio_track": false, "produces_file": true},
      "status": "completed",
      "frame_count": 900,
      "path": "mac_webcam.mp4"
    },
    "iphone": {
      "kind": "video",
      "capabilities": {"provides_audio_track": false, "produces_file": true},
      "status": "completed",
      "frame_count": 900,
      "path": "iphone.mp4"
    }
  }
}

Development

Viewer frontend

The browser viewer's React app lives in src/syncfield/viewer/frontend/. End users do not need Node — published wheels ship the prebuilt SPA in viewer/static/. Only contributors editing the viewer need to rebuild.

Requirements:

  • Node ≥ 22 (pinned in frontend/.nvmrc; enforced via package.json engines). Transitively required by camera-controls (via @react-three/drei).
  • yarn as the single package manager. Do not introduce package-lock.json.
cd src/syncfield/viewer/frontend
nvm use                       # picks Node 22 from .nvmrc (optional)
yarn install --frozen-lockfile
yarn build                    # writes ../static/ — what the FastAPI server serves
yarn dev                      # vite dev server on :5173 (HMR)

The publish workflow runs the same yarn install --frozen-lockfile + yarn build before building the Python wheel, so what you see locally matches what ships on PyPI.

License

Apache-2.0

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

syncfield-0.5.0.tar.gz (1.3 MB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

syncfield-0.5.0-py3-none-any.whl (704.3 kB view details)

Uploaded Python 3

File details

Details for the file syncfield-0.5.0.tar.gz.

File metadata

  • Download URL: syncfield-0.5.0.tar.gz
  • Upload date:
  • Size: 1.3 MB
  • Tags: Source
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/6.1.0 CPython/3.13.12

File hashes

Hashes for syncfield-0.5.0.tar.gz
Algorithm Hash digest
SHA256 097e65261359efd3bf984097fe0586aabb24a0a6e41ed633cabe66af97df5c83
MD5 ec7808d9fa1c29f8953b3b65e85af893
BLAKE2b-256 375298d8b4de86b144be40d91adbe5bd3a835810f5ee0f52282b92992c323621

See more details on using hashes here.

Provenance

The following attestation bundles were made for syncfield-0.5.0.tar.gz:

Publisher: publish.yml on OpenGraphLabs/syncfield-python

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file syncfield-0.5.0-py3-none-any.whl.

File metadata

  • Download URL: syncfield-0.5.0-py3-none-any.whl
  • Upload date:
  • Size: 704.3 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/6.1.0 CPython/3.13.12

File hashes

Hashes for syncfield-0.5.0-py3-none-any.whl
Algorithm Hash digest
SHA256 3ef3132f47384926c3541b44815d8366f2154df0e7144dde3152fa23f995b1d9
MD5 4225988e71e734f1d082b7b5ae3c9269
BLAKE2b-256 74ae5dc04c136eb411accc67e94e37137575df48514728ecaf6d2b780a7a6557

See more details on using hashes here.

Provenance

The following attestation bundles were made for syncfield-0.5.0-py3-none-any.whl:

Publisher: publish.yml on OpenGraphLabs/syncfield-python

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

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