sgn-arrakis

Arrakis source and sink elements for sgn-ts

---

Resources

• Documentation
• Source Code
• Issue Tracker

Installation

pip install sgn-arrakis

Quickstart

Stream data from Arrakis

from sgn_arrakis import ArrakisSource
from sgn.apps import Pipeline

src = ArrakisSource(
    source_pad_names=["L1:GDS-CALIB_STRAIN"],
    start=1187008882,
    duration=64,
)

pipeline = Pipeline()
pipeline.insert(src, ...)
pipeline.run()

Publish data to Arrakis

from sgn_arrakis import ArrakisSink
from sgn.apps import Pipeline

sink = ArrakisSink(
    publisher_id="my-publisher-id",
    sink_pad_names=["H1:GDS-CALIB_STRAIN"],
)

pipeline = Pipeline()
pipeline.insert(..., sink)
pipeline.run()