Add mthds
Browse files
main.py
CHANGED
@@ -67,6 +67,31 @@ def heartbeat():
|
|
67 |
print("Received heartbeat request")
|
68 |
return bkend.heartbeat()
|
69 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
70 |
@app.get(api_base+"/collections")
|
71 |
def list_collections():
|
72 |
print("Received list_collections request")
|
|
|
67 |
print("Received heartbeat request")
|
68 |
return bkend.heartbeat()
|
69 |
|
70 |
+
@app.post(api_base+"/reset")
|
71 |
+
def reset():
|
72 |
+
print("Received reset request")
|
73 |
+
return bkend.reset()
|
74 |
+
|
75 |
+
@app.get(api_base+"/version")
|
76 |
+
def version():
|
77 |
+
print("Received version request")
|
78 |
+
return bkend.version()
|
79 |
+
|
80 |
+
@app.post(api_base+"/persist")
|
81 |
+
def persist():
|
82 |
+
print("Received persist request")
|
83 |
+
return bkend.persist()
|
84 |
+
|
85 |
+
@app.post(api_base+"/raw_sql")
|
86 |
+
def raw_sql(raw_sql: RawSql):
|
87 |
+
print("Received raw_sql request")
|
88 |
+
return bkend.raw_sql(raw_sql)
|
89 |
+
|
90 |
+
@app.get(api_base+"/heartbeat")
|
91 |
+
def heartbeat():
|
92 |
+
print("Received heartbeat request")
|
93 |
+
return bkend.heartbeat()
|
94 |
+
|
95 |
@app.get(api_base+"/collections")
|
96 |
def list_collections():
|
97 |
print("Received list_collections request")
|
server.py
CHANGED
@@ -1,8 +1,7 @@
|
|
1 |
from chromadb.config import Settings
|
2 |
import chromadb
|
3 |
-
|
4 |
from typing import List, Dict, Any, Generator, Optional, cast
|
5 |
-
from server import client
|
6 |
from chromadb.api.types import (
|
7 |
Documents,
|
8 |
Embeddings,
|
@@ -79,4 +78,15 @@ class client():
|
|
79 |
col=self.db.get_collection(name,embedding_function=embedding_function)
|
80 |
print(col)
|
81 |
return col
|
82 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
1 |
from chromadb.config import Settings
|
2 |
import chromadb
|
3 |
+
from pydantic import BaseModel
|
4 |
from typing import List, Dict, Any, Generator, Optional, cast
|
|
|
5 |
from chromadb.api.types import (
|
6 |
Documents,
|
7 |
Embeddings,
|
|
|
78 |
col=self.db.get_collection(name,embedding_function=embedding_function)
|
79 |
print(col)
|
80 |
return col
|
81 |
+
|
82 |
+
def reset():
|
83 |
+
return self.db.reset()
|
84 |
+
|
85 |
+
def version():
|
86 |
+
return self.db.get_version()
|
87 |
+
|
88 |
+
def persist():
|
89 |
+
return self.db.persist()
|
90 |
+
|
91 |
+
def raw_sql(raw_sql: RawSql):
|
92 |
+
return self.db.raw_sql(raw_sql.raw_sql)
|