我们正在处理实时数据，周期性地将数据推入elasticsearch。每当数据被推入elasticsearch时，我都需要处理这些数据，我需要借助python storm获取数据。或者其他方法来实现这个解决方案。你能给我一些用python获取流数据的建议吗？