GeezerVison is showing github.com — pgvector-cpp/examples/sparse/example.cpp at master · pgvector/pgvector-cpp

Expand file tree

example.cpp

Copy path

More file actions

Latest commit

History

76 lines (65 loc) · 2.39 KB

example.cpp

Copy path

File metadata and controls

76 lines (65 loc) · 2.39 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

// good resources

// https://opensearch.org/blog/improving-document-retrieval-with-sparse-semantic-encoders/

// https://huggingface.co/opensearch-project/opensearch-neural-sparse-encoding-v1

// run with

// text-embeddings-router --model-id opensearch-project/opensearch-neural-sparse-encoding-v1 --pooling splade

#include <cstdint>

#include <iostream>

#include <string>

#include <unordered_map>

#include <vector>

#include <cpr/cpr.h>

#include <nlohmann/json.hpp>

#include <pgvector/pqxx.hpp>

#include <pqxx/pqxx>

using json = nlohmann::json;

std::vector<pgvector::SparseVector> embed(const std::vector<std::string>& inputs) {

std::string url{"http://localhost:3000/embed_sparse"};

json data{{"inputs", inputs}};

cpr::Response r = cpr::Post(

cpr::Url{url}, cpr::Body{data.dump()}, cpr::Header{{"Content-Type", "application/json"}}

);

if (r.status_code != 200) {

throw std::runtime_error{"Bad status: " + std::to_string(r.status_code)};

}

json response = json::parse(r.text);

std::vector<pgvector::SparseVector> embeddings;

for (const auto& item : response) {

std::unordered_map<int, float> map;

for (const auto& e : item) {

map.insert({e["index"], e["value"]});

}

embeddings.emplace_back(pgvector::SparseVector{map, 30522});

}

return embeddings;

}

int main() {

pqxx::connection conn{"dbname=pgvector_example"};

pqxx::nontransaction tx{conn};

tx.exec("CREATE EXTENSION IF NOT EXISTS vector");

tx.exec("DROP TABLE IF EXISTS documents");

tx.exec(

"CREATE TABLE documents (id bigserial PRIMARY KEY, content text, embedding sparsevec(30522))"

);

std::vector<std::string> input{

"The dog is barking", "The cat is purring", "The bear is growling"

};

std::vector<pgvector::SparseVector> embeddings = embed(input);

for (size_t i = 0; i < input.size(); i++) {

tx.exec(

"INSERT INTO documents (content, embedding) VALUES ($1, $2)",

pqxx::params{input[i], embeddings[i]}

);

}

std::string query{"forest"};

pgvector::SparseVector query_embedding = embed({query})[0];

pqxx::result result = tx.exec(

"SELECT content FROM documents ORDER BY embedding <#> $1 LIMIT 5",

pqxx::params{query_embedding}

);

for (const auto& row : result) {

std::cout << row[0].as<std::string>() << std::endl;

}

return 0;

}