from logging import getLogger def process(data, pulse_id, timestamp, params): ret = dict() prefix = params["camera_name"] for c in data.keys(): ret[prefix+c] = data[c] return ret