需要开发一个工具:
目的是实现通过配置动态的数据处理python脚本实现灵活的数据处理。
需要配置以下:
1、 数据源,包括kafka、elasticsearch、rabbitmq、mysql等。
2、 处理数据的python脚本,可以传多个。
3、 处理结果存储目标,同数据源。
需要工具从配置好的数据源将数据传入python脚本,脚本处理完将数据返回工具,工具将数据保持到目标数据源。
需要开发一个工具:
目的是实现通过配置动态的数据处理python脚本实现灵活的数据处理。
需要配置以下:
1、 数据源,包括kafka、elasticsearch、rabbitmq、mysql等。
2、 处理数据的python脚本,可以传多个。
3、 处理结果存储目标,同数据源。
需要工具从配置好的数据源将数据传入python脚本,脚本处理完将数据返回工具,工具将数据保持到目标数据源。