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
}