|
22 | 22 | import requests |
23 | 23 | from pydantic import Field |
24 | 24 | from typing_extensions import override |
25 | | -from veadk.utils.misc import getenv |
| 25 | +from volcengine.viking_knowledgebase import VikingKnowledgeBaseService |
| 26 | + |
26 | 27 | import veadk.config # noqa E401 |
27 | 28 | from veadk.auth.veauth.utils import get_credential_from_vefaas_iam |
28 | 29 | from veadk.configs.database_configs import NormalTOSConfig, TOSConfig |
29 | 30 | from veadk.knowledgebase.backends.base_backend import BaseKnowledgebaseBackend |
30 | | -from veadk.knowledgebase.backends.utils import build_vikingdb_knowledgebase_request |
| 31 | +from veadk.knowledgebase.backends.utils import ( |
| 32 | + build_vikingdb_knowledgebase_request, |
| 33 | +) |
31 | 34 | from veadk.knowledgebase.entry import KnowledgebaseEntry |
32 | 35 | from veadk.utils.logger import get_logger |
33 | | -from veadk.utils.misc import formatted_timestamp |
34 | | -from volcengine.viking_knowledgebase import VikingKnowledgeBaseService |
| 36 | +from veadk.utils.misc import formatted_timestamp, getenv |
35 | 37 |
|
36 | 38 | try: |
37 | 39 | from veadk.integrations.ve_tos.ve_tos import VeTOS |
@@ -111,7 +113,9 @@ class VikingDBKnowledgeBackend(BaseKnowledgebaseBackend): |
111 | 113 | ) |
112 | 114 | session_token: str = "" |
113 | 115 |
|
114 | | - volcengine_project: str = "default" |
| 116 | + volcengine_project: str = Field( |
| 117 | + default_factory=lambda: os.getenv("DATABASE_VIKING_PROJECT", "default") |
| 118 | + ) |
115 | 119 |
|
116 | 120 | region: str = "cn-beijing" |
117 | 121 | base_url: str = "https://api-knowledgebase.mlp.cn-beijing.volces.com" |
@@ -562,7 +566,9 @@ def _search_knowledge( |
562 | 566 |
|
563 | 567 | def _set_service_info(self): |
564 | 568 | env_host = getenv( |
565 | | - "DATABASE_VIKING_BASE_URL", default_value=None, allow_false_values=True |
| 569 | + "DATABASE_VIKING_BASE_URL", |
| 570 | + default_value=None, |
| 571 | + allow_false_values=True, |
566 | 572 | ) |
567 | 573 | if env_host: |
568 | 574 | if env_host.startswith("http://") or env_host.startswith("https://"): |
|
0 commit comments