fix: Consumer XREADGROUP last_id='>' + version统一3.1 + 存储路径统一到~/projects/zhiyi/data

This commit is contained in:
小唯 A06 2026-05-27 11:18:50 +08:00
parent 119257c7c1
commit 6836d91c4d
6 changed files with 6 additions and 6 deletions

View File

@ -145,5 +145,5 @@ def get_config():
'decay_rate': 0.015,
'decay_floor': 0.1,
'distill_threshold': 0.7,
'version': '3.0'
'version': '3.1'
}

View File

@ -9,7 +9,7 @@ from pathlib import Path
router = APIRouter()
GRAPH_DB = Path.home() / '.memory-fabric' / 'zhiyi' / 'graph.db'
GRAPH_DB = Path.home() / 'projects' / 'zhiyi' / 'data' / 'graph.db'
class GraphNode(BaseModel):

View File

@ -32,7 +32,7 @@ def _start_event_consumer():
if not redis:
logging.warning("[Consumer] Redis 不可用")
return
last_id = '$'
last_id = '>'
logging.info("[Consumer] 启动")
# 确保消费组存在MKSTREAM流不存在则自动创建
try:

View File

@ -16,7 +16,7 @@ from datetime import datetime
from typing import Optional
GRAPH_DB = Path('~/.memory-fabric/zhiyi/graph.db').expanduser()
GRAPH_DB = Path.home() / 'projects' / 'zhiyi' / 'data' / 'graph.db'
def _get_conn() -> sqlite3.Connection:

View File

@ -6,7 +6,7 @@ from datetime import datetime
from typing import Iterator, Optional, Callable
class JSONLShardStore:
def __init__(self, base_dir: str = '~/.memory-fabric', namespace: str = 'zhiyi'):
def __init__(self, base_dir: str = '~/projects/zhiyi/data', namespace: str = 'zhiyi'):
self.base_dir = Path(base_dir).expanduser()
self.namespace = namespace

View File

@ -3,7 +3,7 @@ from datetime import datetime
from pathlib import Path
class TombstoneStore:
def __init__(self, base_dir: str = '~/.memory-fabric', namespace: str = 'zhiyi'):
def __init__(self, base_dir: str = '~/projects/zhiyi/data', namespace: str = 'zhiyi'):
self.base_dir = Path(base_dir).expanduser()
self.namespace = namespace
self.tombstones_file = self.base_dir / self.namespace / 'tombstones.json'