skywalking9.3.0源码中涉及到数据持久化到es7数据库的方法有哪些 具体流程是怎样的 es的文档写入api的具体位置和方法名都是什么
时间: 2024-05-19 12:11:14 浏览: 85
数据持久化
在SkyWalking 9.3.0中,涉及到数据持久化到ES7数据库的方法有:
1. Trace数据的写入:在org.apache.skywalking.oap.server.storage.plugin.elasticsearch7.dao.TraceEs7DAO类中,通过Elasticsearch High Level REST Client使用Index API将Trace数据写入到ES7中。
2. Metric数据的写入:在org.apache.skywalking.oap.server.storage.plugin.elasticsearch7.dao.MetricEs7DAO类中,通过Elasticsearch High Level REST Client使用Bulk API将Metric数据批量写入到ES7中。
具体流程如下:
1. 当SkyWalking收集到Trace或Metric数据时,会将数据传递给对应的DAO类。
2. DAO类通过Elasticsearch High Level REST Client连接到ES7,构建对应的IndexRequest或BulkRequest对象。
3. 将数据写入ES7。
4. 如果写入失败,则会进行重试。
ES的文档写入API的具体位置是https://www.elastic.co/guide/en/elasticsearch/client/java-rest/7.0/java-rest-high-document-index.html,方法名是index。
阅读全文