Измените пакет с Elastigo на Olivere, чтобы вставить данные в Elasticsearch - PullRequest
0 голосов
/ 22 ноября 2018

Предыдущий код при использовании Elastigo

var es = elastigo.NewConn()
var indexer = es.NewBulkIndexer(50)

// Create a custom Sender Func, so that we can check what the error is
indexer.Sender = func(buf *bytes.Buffer) error {

    resp, err := c_es.DoCommand("POST", "/_bulk", nil, buf)
    if err != nil {

        fmt.Println("Error", string(resp)) 
        fmt.Println("Error", err)
    }

    if err == nil {
        fmt.Println("Succeed")
    }
    return err
}

Я могу изменить какой-то код на olivere, но я не знаю, как изменить остальные.Подключение кasticsearch с использованием Olivere легко.

// Connect to elasticsearch 
olivere_es, err = elastic.NewClient(elastic.SetURL("http:144.00.0.34:9400"))

//Replace the code for the var indexer = es.NewBulkIndexer(50)
var oliveIndexer = elastic.NewBulkService(olivere_es)

Но я понятия не имею, как изменить indexer.Sender и indexer.Start ().Кто-нибудь знает, что это за функции?

Спасибо

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...