смотри, есть несолько вариантов, или ты грузишь из своейт базы (выгурзитьжурналРегистрации) и отправляешь, но я делал по другому. Я делал отдельную базу для обработки ЖР, ставил в базах разбивать в ЖР по часу, а вот эта отдельная база собирала мне со всехзх баз раз в часвсе ЖР и отправляла в эластик. т.е. рабочую базу я не дорабатывал вообще. ну и всегда можно подкинуть еще одну базу для выгрузки без доработок.