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.6.0.tar.gz (1.4 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.6.0-py3-none-any.whl (745.5 kB view details)

Uploaded Python 3

File details

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

File metadata

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

File hashes

Hashes for syncfield-0.6.0.tar.gz
Algorithm Hash digest
SHA256 2644b97258759ad3400e4c2f38abc7d453f2c8b866cc6f854961d16d88fb26f5
MD5 69b037415ac4ecfbb19d01238ab5a188
BLAKE2b-256 59c08f203659aa3a34625cbce5779a53c4a6aee96b0a3e4c688a12c1c356c726

See more details on using hashes here.

Provenance

The following attestation bundles were made for syncfield-0.6.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.6.0-py3-none-any.whl.

File metadata

  • Download URL: syncfield-0.6.0-py3-none-any.whl
  • Upload date:
  • Size: 745.5 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.6.0-py3-none-any.whl
Algorithm Hash digest
SHA256 fd032fcdcfc4e832ac1305773cb4444f4d1da765a44fb315da39ccf4df96cea1
MD5 120099524826a6cbd8d45c64d0a07c53
BLAKE2b-256 a26797e4b8dd077da6338104f82d14ee2b4002fe75d4789e2bed1e662e5b26c0

See more details on using hashes here.

Provenance

The following attestation bundles were made for syncfield-0.6.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