Как восстановить структуру из документа в пакете Golang, Bleve

Question

Было бы наиболее удобно, если бы я смог вернуть индексированную структуру из моего Bleve SearchResults. Это то, что я знаю и что у меня есть: у меня есть SearchResults.Hits который я могу перебрать и получить документ с index.Document(hit.ID). С документом у меня также есть доступ к его полям. Что я мог сделать, так это вручную восстановить структуру. Однако в другом вопросе о Bleve здесь упоминалось, что можно использовать index.GetInternal(hit.ID)чтобы вернуть исходную структуру, если был установлен внутренний индекс. Там есть index.SetInternal(key, val []byte) error, но я очень не понимаю, как использовать это для достижения того, что я хочу. Я покопался в коде, но, честно говоря, мои ограниченные знания не внесли никаких изменений. Как я мог настроить его так, чтобы мне нужно было только вызывать index.GetInternal получить структуру из моих результатов поиска?

Answer 1

Марти Шох больше не рекомендует это решение .

Вместо этого он предложил:

• закодируйте свою структуру:

          doc := document.Document{
        ID: post.URI,
    }
    if err := bleve.NewIndexMapping().MapDocument(&doc, post); err != nil {
        return errors.Errorf("failed to map document: %v", err)
    }

    var b bytes.Buffer
    enc := gob.NewEncoder(&b)
    if err := enc.Encode(post); err != nil {
        return errors.Errorf("failed to encode post: %v", err)
    }

• добавить новое поле для хранения закодированных байтов:

          field := document.NewTextFieldWithIndexingOptions("_source", nil, b.Bytes(), document.StoreField)
    if err := batch.IndexAdvanced(doc.AddField(field)); err != nil {
        return errors.Errorf("failed to add index to the batch: %v", err)
    }

• расшифровать результаты поиска:

          query := bleve.NewMatchQuery(value)
    request := bleve.NewSearchRequest(query)
    request.Fields = []string{"_source"}
    searchResults, err := ps.index.Search(request)
    if err != nil {
        return nil, errors.Errorf("failed to execute a search request: %v", err)
    }

    var searchPosts []*blog.Post
    for _, result := range searchResults.Hits {
        var post *blog.Post
        b := bytes.NewBuffer([]byte(fmt.Sprintf("%v", result.Fields["_source"])))
        dec := gob.NewDecoder(b)
        if err = dec.Decode(&post); err != nil {
            return nil, errors.Errorf("failed to decode post: %v", err)
        }
        searchPosts = append(searchPosts, post)
    }

Источник: https://gist.github.com/michaeljs1990/25f9949c10ab64d971422dda44feea0e