flume怎么从redis读取数据，sink的时候怎么按照我自己的规则格式保存日志

如题

flume要从redis读取数据要自定义source吗？自定义source应该怎么写？