Crear archivo json para bulk en elastic

bulk_elastic_go.go

func CreateElasticIndexData(products []models.Product) error {

	file, err := os.Create("archivo.json")
	if err != nil {
		fmt.Println(err)
		return err
	}
	w := bufio.NewWriter(file)

	defer file.Close()

	for _, value := range products {

		response := fmt.Sprintf(`{"index":{"_id":%s}}`, value.ItemNumber)

		fmt.Fprintln(w, response)

		productJson, _ := json.Marshal(value)

		fmt.Fprintln(w, string(productJson))

	}
	return w.Flush()
}