StormCrawler был бы намного лучше для достижения этой цели - он был разработан, чтобы иметь возможность обслуживать сценарии, подобные описанному вами.Вам нужно было бы написать собственный излив, соединяющийся с Redis, повторно использовать болты сборщика и анализатора, а затем добавить болты с вашей собственной обработкой.Некоторые из первых пользователей SC делали именно это