Мы обрабатывали данные в реальном времени, периодически данные помещались в эластичный поиск. Мне нужно обрабатывать эти данные всякий раз, когда данные помещаются вasticsearch, мне нужно получать данные с помощью Python Storm. Или любые другие способы достижения этого решения. Можете ли вы дать мне несколько советов для получения потоковых данных в Python?