hongze_cygx/services/elasticsearch.go

package services

import (
	"fmt"
	"context"
	"gopkg.in/olivere/elastic.v5"
	"gopkg.in/olivere/elastic.v5/config"
	//"hongze/hongze_cygx/models"
)

const (
	ES_URL      = "http://es-cn-oew21y5tl000i1wxm.public.elasticsearch.aliyuncs.com:9200"     //<1>
	ES_USERNAME = "elastic"        //<2>
	ES_PASSWORD = "hongze@2021"       //<3>
)

func SaveData()  {
	fmt.Println("start")
	var sniff = false    //<4>
	cfg := &config.Config{
		URL:      ES_URL,
		Username: ES_USERNAME,
		Password: ES_PASSWORD,
	}

	cfg.Sniff = &sniff
	var client, err = elastic.NewClientFromConfig(cfg)
	if err != nil {
		fmt.Println("NewClientFromConfig Err:"+err.Error())
		return
	}
	var esIndex = "cygx_article"
	exists, err := client.IndexExists(esIndex).Do(context.Background())   //<5>
	if err != nil {
		fmt.Println("IndexExists Err:"+err.Error())
		return
	}
	if !exists {
		_,err=client.CreateIndex(esIndex).Do(context.Background())
		if err!=nil {
			fmt.Println("CreateIndex Err:"+err.Error())
			return
		}
	}
	//item:=new(models.CygxArticle)
	//item.Article_id
	fmt.Println(exists)
	fmt.Println("end")
}