1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
| package insertdata
|
| import (
| "plugin"
| "ruleprocess/structure"
| )
|
|
| func InsertToEs(msg structure.ResultMsg) {
| p,err := plugin.Open("./algorithm/insertEs.so")
| if err != nil {
| panic(err)
| }
| f,err1 := p.Lookup("InsertToEs")
| if err1 != nil {
| panic("没有找到中间件的格式化数据函数")
| }
| f.(func(msg structure.ResultMsg))(msg)
| }
|
|
