from collections import OrderedDict from cam_server.pipeline.data_processing import functions, processor def process_image(image, pulse_id, timestamp, x_axis, y_axis, parameters, bsdata): ret = OrderedDict() r = processor.process_image(image, pulse_id, timestamp, x_axis, y_axis, parameters, bsdata) channels = ["intensity","x_fit_mean","y_fit_mean"] prefix = parameters["camera_name"] #for c in channels: # ret[prefix+":"+c] = r[c] ret[prefix+":intensity"] = r["intensity"] ret[prefix+":x_fit_mean_v2"] = r["x_fit_mean"] ret[prefix+":y_fit_mean"] = r["y_fit_mean"] #ret["SARES20-PROF141-M1:intensity"] = 1281954 #ret["SARES20-PROF141-M1:x_fit_mean"] = 708.7 #ret["SARES20-PROF141-M1:y_fit_mean"] = 539.3 return ret