Парсинг логов при помощи fluentd

Можно ли как-то парсить логи по разделителю (в моем случае в роли разделителя идет "===") с помощью fluentd? Пример: На вход приходят данные "message==='success', user_id===1" На выходе получаем {'message': 'success', 'user_id': 1}