需要开发一个工具：
目的是实现通过配置动态的数据处理python脚本实现灵活的数据处理。
需要配置以下：
1、 数据源，包括kafka、elasticsearch、rabbitmq、mysql等。
2、 处理数据的python脚本，可以传多个。
3、 处理结果存储目标，同数据源。
需要工具从配置好的数据源将数据传入python脚本，脚本处理完将数据返回工具，工具将数据保持到目标数据源。
把每种输入和输出写出类库来，然后通过判断配置文件，调用对应的方法
思路很清晰
问题是你得一个一个的去实现，先实现一个再说
别空谈