我有一個(gè)文檔數(shù)組來批量索引使用 github.com/elastic/go-elasticsearch/v8 庫。每個(gè)文檔都可以添加到少數(shù)幾個(gè)不同索引之一，因此我的代碼如下所示： var indexers map[string]esutil.BulkIndexer = make(map[string]esutil.BulkIndexer) for i := range documents { var bi esutil.BulkIndexer var ok bool var err error if bi, ok = indexers[documents[i].index]; !ok { bi, err = esutil.NewBulkIndexer(esutil.BulkIndexerConfig{ Index: documents[i].index, // The index name Client: client, // The Elasticsearch client* Same isntance for all indexers* NumWorkers: BULK_NUM_WORKERS, // The number of worker goroutines FlushBytes: int(BULK_FLUSHBYTES), // The flush threshold in bytes FlushInterval: 5 * time.Second, // The periodic flush interval }) if err != nil { fmt.Printf("Error creating the indexer: %s", err) continue } indexers[documents[i].indexName] = bi }這個(gè)想法是我有一個(gè)地圖，它們都共享相同的實(shí)例。所以我的問題是，幾個(gè)人共享相同的實(shí)例是否可行且安全，或者它們各自需要一個(gè)單獨(dú)的實(shí)例？esutil.BulkIndexerelasticsearch.Clientesutil.BulkIndexerelasticsearch.Clientelasticsearch.Client
1 回答
桃花長相依
TA貢獻(xiàn)1860條經(jīng)驗(yàn) 獲得超8個(gè)贊
找不到官方文檔的詳細(xì)信息。但是，查看此鏈接，建議在并行請(qǐng)求的工作線程（go例程）之間共享客戶端。
客戶端連接是在包初始化時(shí)創(chuàng)建的，并且以并行方式發(fā)生的后續(xù)請(qǐng)求共享同一客戶端。
從上面的鏈接
package httpexample
import (
"github.com/elastic/go-elasticsearch/v7"
)
var client *elasticsearch.Client
func init() {
var err error
... # Client configuration
client, err = elasticsearch.NewClient(cfg)
if err != nil {
log.Fatalf("elasticsearch.NewClient: %v", err)
}
}
//This method will be called in parallel
func HttpExample(w http.ResponseWriter, r *http.Request) {
... # Client usage
}
注意：我是專家，可以推薦使用多個(gè)批量索引器。
- 1 回答
- 0 關(guān)注
- 90 瀏覽
添加回答
舉報(bào)
0/150
提交
取消