로깅

aerospike-py에는 Rust-to-Python logging bridge가 내장되어 있습니다. 내부 Rust log를 Python logging module로 전달하며 package를 import할 때 자동으로 초기화됩니다.

Quick Start

import logging
import aerospike_py

logging.basicConfig(level=logging.DEBUG)

client = aerospike_py.client({"hosts": [("127.0.0.1", 3000)]}).connect()
# DEBUG:aerospike_core::cluster: Connecting to seed 127.0.0.1:3000

Log Level 제어

aerospike_py.set_log_level(aerospike_py.LOG_LEVEL_DEBUG)

Constant	Value	Python Level
LOG_LEVEL_OFF	-1	(disabled)
LOG_LEVEL_ERROR	0	ERROR (40)
LOG_LEVEL_WARN	1	WARNING (30)
LOG_LEVEL_INFO	2	INFO (20)
LOG_LEVEL_DEBUG	3	DEBUG (10)
LOG_LEVEL_TRACE	4	TRACE (5)

Logger 이름

Logger	설명
aerospike_core::cluster	cluster discovery, node 관리
aerospike_core::batch	batch operation 실행
aerospike_core::command	개별 command 실행
aerospike_py	Python-side client wrapper

# 세분화된 제어
logging.getLogger("aerospike_core::cluster").setLevel(logging.DEBUG)
logging.getLogger("aerospike_core::batch").setLevel(logging.WARNING)

JSON Logging

import logging, json

class JSONFormatter(logging.Formatter):
    def format(self, record):
        return json.dumps({
            "timestamp": self.formatTime(record),
            "level": record.levelname,
            "logger": record.name,
            "message": record.getMessage(),
        })

handler = logging.StreamHandler()
handler.setFormatter(JSONFormatter())
logger = logging.getLogger("aerospike_core")
logger.addHandler(handler)
logger.setLevel(logging.DEBUG)

Framework 통합

FastAPI

import logging
from contextlib import asynccontextmanager
import aerospike_py
from fastapi import FastAPI

logging.basicConfig(level=logging.INFO, format="%(asctime)s %(name)s %(levelname)s %(message)s")

@asynccontextmanager
async def lifespan(app: FastAPI):
    aerospike_py.set_log_level(aerospike_py.LOG_LEVEL_INFO)
    client = aerospike_py.AsyncClient({"hosts": [("127.0.0.1", 3000)]})
    await client.connect()
    app.state.aerospike = client
    yield
    await client.close()

app = FastAPI(lifespan=lifespan)

Django

# settings.py
LOGGING = {
    "version": 1,
    "handlers": {"console": {"class": "logging.StreamHandler"}},
    "loggers": {
        "aerospike_core": {"handlers": ["console"], "level": "INFO"},
        "aerospike_py": {"handlers": ["console"], "level": "INFO"},
    },
}

File Logging

import logging

handler = logging.FileHandler("aerospike.log")
handler.setFormatter(logging.Formatter("%(asctime)s %(levelname)s %(name)s %(message)s"))

for name in ["aerospike_core", "aerospike_py"]:
    logger = logging.getLogger(name)
    logger.addHandler(handler)
    logger.setLevel(logging.DEBUG)

Shutdown Fallback

Interpreter가 종료되는 동안처럼 Python GIL을 사용할 수 없으면 logging bridge가 메시지를 Python으로 전달할 수 없습니다. 이 경우 다음과 같이 동작합니다.

• WARN과 ERROR 메시지는 중요한 진단 정보가 사라지지 않도록 stderr에 출력합니다.
• INFO, DEBUG, TRACE 메시지는 버립니다.

버린 메시지 수는 dropped_log_count()로 확인할 수 있습니다.

import aerospike_py

# client shutdown 후
count = aerospike_py.dropped_log_count()
if count > 0:
    print(f"{count} log messages were dropped (GIL unavailable)")

비활성화

aerospike_py.set_log_level(aerospike_py.LOG_LEVEL_OFF)