Hermes Client
Async Python client for Hermes search server.
Installation
pip install hermes-client-python
Quick Start
import asyncio
from hermes_client_python import HermesClient
async def main():
async with HermesClient("localhost:50051") as client:
# Create index with SDL schema
await client.create_index(
"articles",
"""
index articles {
field title: text [indexed, stored]
field body: text [indexed, stored]
field score: f64 [stored]
}
""",
)
# Index documents
await client.index_documents(
"articles",
[
{"title": "Hello World", "body": "First article", "score": 1.5},
{"title": "Goodbye World", "body": "Last article", "score": 2.0},
],
)
# Commit changes
await client.commit("articles")
# Search
results = await client.search("articles", term=("title", "hello"), limit=10)
for hit in results.hits:
print(f"Doc {hit.doc_id}: score={hit.score}, fields={hit.fields}")
# Get document by ID
doc = await client.get_document("articles", 0)
print(doc.fields)
# Delete index
await client.delete_index("articles")
asyncio.run(main())
API Reference
HermesClient
client = HermesClient(address="localhost:50051")
Connection
# Using context manager (recommended)
async with HermesClient("localhost:50051") as client:
...
# Manual connection
client = HermesClient("localhost:50051")
await client.connect()
# ... use client ...
await client.close()
Index Management
# Create index with SDL schema
await client.create_index(
"myindex",
"""
index myindex {
field title: text [indexed, stored]
field body: text [indexed, stored]
}
""",
)
# Create index with JSON schema
await client.create_index(
"myindex",
"""
{
"fields": [
{"name": "title", "type": "text", "indexed": true, "stored": true},
{"name": "body", "type": "text", "indexed": true, "stored": true}
]
}
""",
)
# Get index info
info = await client.get_index_info("myindex")
print(f"Documents: {info.num_docs}, Segments: {info.num_segments}")
# Delete index
await client.delete_index("myindex")
Document Indexing
# Index multiple documents (batch)
indexed, errors = await client.index_documents(
"myindex",
[
{"title": "Doc 1", "body": "Content 1"},
{"title": "Doc 2", "body": "Content 2"},
],
)
# Index single document
await client.index_document("myindex", {"title": "Doc", "body": "Content"})
# Stream documents (for large datasets)
async def doc_generator():
for i in range(10000):
yield {"title": f"Doc {i}", "body": f"Content {i}"}
count = await client.index_documents_stream("myindex", doc_generator())
# Commit changes (required to make documents searchable)
num_docs = await client.commit("myindex")
# Force merge segments (for optimization)
num_segments = await client.force_merge("myindex")
Searching
# Term query
results = await client.search("myindex", term=("title", "hello"), limit=10)
# Boolean query
results = await client.search(
"myindex",
boolean={
"must": [("title", "hello")],
"should": [("body", "world")],
"must_not": [("title", "spam")],
},
)
# With pagination
results = await client.search("myindex", term=("title", "hello"), limit=10, offset=20)
# With field loading
results = await client.search(
"myindex", term=("title", "hello"), fields_to_load=["title", "body"]
)
# Access results
for hit in results.hits:
print(f"Doc {hit.doc_id}: {hit.score}")
print(f" Title: {hit.fields.get('title')}")
print(f"Total hits: {results.total_hits}")
print(f"Took: {results.took_ms}ms")
Document Retrieval
# Get document by ID
doc = await client.get_document("myindex", doc_id=42)
if doc:
print(doc.fields["title"])
Field Types
| Type | Python Type | Description |
|---|---|---|
text |
str |
Full-text searchable string |
u64 |
int (>= 0) |
Unsigned 64-bit integer |
i64 |
int |
Signed 64-bit integer |
f64 |
float |
64-bit floating point |
bytes |
bytes |
Binary data |
json |
dict / list |
JSON object (auto-serialized) |
dense_vector |
list[float] |
Dense vector for semantic search |
sparse_vector |
dict |
Sparse vector with indices and values |
Error Handling
import grpc
try:
await client.search("nonexistent", term=("field", "value"))
except grpc.RpcError as e:
if e.code() == grpc.StatusCode.NOT_FOUND:
print("Index not found")
else:
raise
Development
Generate protobuf stubs:
pip install grpcio-tools
python generate_proto.py
License
MIT
Timeouts / deadlines
Every RPC accepts an optional timeout (seconds) which sets a gRPC deadline;
a client-wide default can be set in the constructor. On expiry the call
raises grpc.aio.AioRpcError with DEADLINE_EXCEEDED.
client = HermesClient("localhost:50051", default_timeout=5.0)
results = await client.search("articles", query={...}, timeout=0.5) # per-call override
await client.force_merge("articles", timeout=3600) # long op, long deadline
1 maintainer
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file hermes_client_python-1.8.86.tar.gz.
File metadata
- Download URL: hermes_client_python-1.8.86.tar.gz
- Upload date:
- Size: 17.6 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via:
uv/0.11.32 {"installer":{"name":"uv","version":"0.11.32","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
aade2f3480c131caaed97ac0c3eac8d081d2be92e9248517f72ba006b2f7a5d2
|
|
| MD5 |
a4b968450725b68ff755a2e61bed4ff1
|
|
| BLAKE2b-256 |
cc574da9f4158ced34c3ca863a94be8c55df0c9fc167c6b99ec6969c76dad2bc
|
File details
Details for the file hermes_client_python-1.8.86-py3-none-any.whl.
File metadata
- Download URL: hermes_client_python-1.8.86-py3-none-any.whl
- Upload date:
- Size: 19.1 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via:
uv/0.11.32 {"installer":{"name":"uv","version":"0.11.32","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
2a813b6961e5f901ad6f8f7be7193d7bf83b6ba8d13f22a8c52d377ce393e230
|
|
| MD5 |
6e1c906f50718cb3c40b1c5549a97661
|
|
| BLAKE2b-256 |
1e72edac875171799989768e6135a07eff7fc30833bd988b6d91550fa22dd92b
|
