bluesky_plan_with_custom_callback.py

import bluesky.plan_stubs as bps
import bluesky.plans as bp
from bluesky.callbacks.best_effort import BestEffortCallback
from bluesky.run_engine import RunEngine
from bluesky.utils import install_kicker
from databroker import Broker
from ophyd.sim import det, motor
import matplotlib.pyplot as plt

plt.ion()

RE = RunEngine()
db = Broker.named('temp')
bec = BestEffortCallback()

RE.subscribe(db.insert)
RE.subscribe(bec)
install_kicker()

def my_table(name, doc):
    if name == 'event':
        diff = doc['data']['motor'] - doc['data']['motor_setpoint']
        print(f'The diff is: {diff}')

RE.subscribe(my_table)

# Run next:
RE(bp.scan([det], motor, -10, 10, 5))