from collections import OrderedDict from cam_server.pipeline.data_processing import functions from logging import getLogger _logger = getLogger(__name__) def process_image(image, pulse_id, timestamp, x_axis, y_axis, parameters, bsdata): ret = OrderedDict() prefix = parameters["camera_name"] (x_profile, y_profile) = functions.get_x_y_profile(image) ret[prefix+":x_profile"] = x_profile ret[prefix+":y_profile"] = y_profile return ret