from cam_server.pipeline.data_processing import functions, processor def process_image(image, pulse_id, timestamp, x_axis, y_axis, parameters, bsdata=None): ret = {} prefix = parameters["camera_name"]+":" (x_profile, y_profile) = functions.get_x_y_profile(image) intensity = x_profile.sum() ret[prefix+"x_profile"] = x_profile ret[prefix+"y_profile"] = y_profile ret[prefix+"intensity"] = intensity ret.update(bsdata) return ret