Skip to content

Commit 44bd6b1

Browse files
committed
Update the algorithm implementation
1 parent e29e478 commit 44bd6b1

File tree

4 files changed

+144
-216
lines changed

4 files changed

+144
-216
lines changed

backend/common/dataclasses.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,6 @@ class UploadUrl:
7070
class SnowflakeInfo:
7171
timestamp: int
7272
datetime: str
73-
cluster_id: int
74-
node_id: int
73+
datacenter_id: int
74+
worker_id: int
7575
sequence: int

backend/core/conf.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -53,13 +53,13 @@ class Settings(BaseSettings):
5353
REDIS_TIMEOUT: int = 5
5454

5555
# .env Snowflake
56-
SNOWFLAKE_CLUSTER_ID: int | None = None
57-
SNOWFLAKE_NODE_ID: int | None = None
56+
SNOWFLAKE_DATACENTER_ID: int | None = None
57+
SNOWFLAKE_WORKER_ID: int | None = None
5858

5959
# Snowflake
6060
SNOWFLAKE_REDIS_PREFIX: str = 'fba:snowflake'
61-
SNOWFLAKE_HEARTBEAT_INTERVAL: int = 30 # 心跳间隔(秒)
62-
SNOWFLAKE_NODE_TTL: int = 60 # 节点存活时间(秒)
61+
SNOWFLAKE_HEARTBEAT_INTERVAL_SECONDS: int = 30
62+
SNOWFLAKE_NODE_TTL_SECONDS: int = 60
6363

6464
# .env Token
6565
TOKEN_SECRET_KEY: str # 密钥 secrets.token_urlsafe(32)

backend/core/registrar.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ async def register_init(app: FastAPI) -> AsyncGenerator[None, None]:
5959
)
6060

6161
# 初始化 snowflake 节点
62-
await snowflake.initialize()
62+
await snowflake.init()
6363

6464
# 创建操作日志任务
6565
create_task(OperaLogMiddleware.consumer())

0 commit comments

Comments
 (0)