我正在尝试从日志服务器创建一个日志文件，并将其推入oracle。有没有一种方法可以使用flume（没有hdfs设置）将日志文件推送到oracle中？任何帮助都将不胜感激。
daupos2t1#
为了将数据持久化到oracle中，您需要创建一个自定义接收器。这是相对容易的，你只需要扩展 AbstrackSink 类并实现 process() 方法（基本上，从通道获取事件并使用oracleapi来持久化数据）。
AbstrackSink
process()
1条答案
按热度按时间daupos2t1#
为了将数据持久化到oracle中，您需要创建一个自定义接收器。这是相对容易的，你只需要扩展
AbstrackSink类并实现process()方法（基本上，从通道获取事件并使用oracleapi来持久化数据）。