golang 和elastic的连接,使用了包:https://github.com/olivere/elastic
func UpsertType(esIndexName string, esTypeName string, idStr string, bodyJson interface{}) error{
var err error
ctx := context.Background()
client, err := Client()
upsertResult, err := client.Index().
Index(esIndexName).
Type(esTypeName).
Id(idStr).
BodyJson(bodyJson).
Do(ctx)
if err != nil {
return err
}
log.Printf("Indexed tweet %s to index %s, type %s\n", upsertResult.Id, upsertResult.Index, upsertResult.Type)
return err
}