Migrate infrastructure apps to centralized aitbc package utilities

- Migrate monitor/monitor.py from logging to aitbc.get_logger and hardcoded paths to DATA_DIR
- Migrate multi-region-load-balancer/main.py from logging to aitbc.get_logger
- Migrate global-infrastructure/main.py from logging to aitbc.get_logger
- Migrate global-ai-agents/main.py from logging to aitbc.get_logger
- Migrate exchange-integration/main.py from logging to aitbc.get_logger
- Migrate trading-engine/main.py from logging to aitbc.get_logger
- Migrate compliance-service/main.py from logging to aitbc.get_logger
- Remove logging.basicConfig() calls from all files
This commit is contained in:
aitbc
2026-04-25 07:23:45 +02:00
parent 2f3a0a9fa5
commit b316259df8
7 changed files with 23 additions and 29 deletions

View File

@@ -5,7 +5,6 @@ Handles KYC/AML, regulatory compliance, and monitoring
import asyncio import asyncio
import json import json
import logging
from datetime import datetime, timedelta from datetime import datetime, timedelta
from pathlib import Path from pathlib import Path
from typing import Dict, Any, List, Optional from typing import Dict, Any, List, Optional
@@ -13,9 +12,9 @@ from fastapi import FastAPI, HTTPException
from pydantic import BaseModel from pydantic import BaseModel
from contextlib import asynccontextmanager from contextlib import asynccontextmanager
# Configure logging from aitbc import get_logger
logging.basicConfig(level=logging.INFO)
logger = logging.getLogger(__name__) logger = get_logger(__name__)
@asynccontextmanager @asynccontextmanager
async def lifespan(app: FastAPI): async def lifespan(app: FastAPI):

View File

@@ -5,7 +5,6 @@ Handles real exchange connections and trading operations
import asyncio import asyncio
import json import json
import logging
from datetime import datetime from datetime import datetime
from pathlib import Path from pathlib import Path
from typing import Dict, Any, List, Optional from typing import Dict, Any, List, Optional
@@ -13,9 +12,9 @@ import aiohttp
from fastapi import FastAPI, HTTPException from fastapi import FastAPI, HTTPException
from pydantic import BaseModel from pydantic import BaseModel
# Configure logging from aitbc import get_logger
logging.basicConfig(level=logging.INFO)
logger = logging.getLogger(__name__) logger = get_logger(__name__)
app = FastAPI( app = FastAPI(
title="AITBC Exchange Integration Service", title="AITBC Exchange Integration Service",

View File

@@ -5,16 +5,15 @@ Handles cross-chain and cross-region AI agent communication with global optimiza
import asyncio import asyncio
import json import json
import logging
from datetime import datetime, timedelta from datetime import datetime, timedelta
from pathlib import Path from pathlib import Path
from typing import Dict, Any, List, Optional from typing import Dict, Any, List, Optional
from fastapi import FastAPI, HTTPException from fastapi import FastAPI, HTTPException
from pydantic import BaseModel from pydantic import BaseModel
# Configure logging from aitbc import get_logger
logging.basicConfig(level=logging.INFO)
logger = logging.getLogger(__name__) logger = get_logger(__name__)
app = FastAPI( app = FastAPI(
title="AITBC Global AI Agent Communication Service", title="AITBC Global AI Agent Communication Service",

View File

@@ -5,16 +5,15 @@ Handles multi-region deployment, load balancing, and global optimization
import asyncio import asyncio
import json import json
import logging
from datetime import datetime, timedelta from datetime import datetime, timedelta
from pathlib import Path from pathlib import Path
from typing import Dict, Any, List, Optional from typing import Dict, Any, List, Optional
from fastapi import FastAPI, HTTPException from fastapi import FastAPI, HTTPException
from pydantic import BaseModel from pydantic import BaseModel
# Configure logging from aitbc import get_logger
logging.basicConfig(level=logging.INFO)
logger = logging.getLogger(__name__) logger = get_logger(__name__)
app = FastAPI( app = FastAPI(
title="AITBC Global Infrastructure Service", title="AITBC Global Infrastructure Service",

View File

@@ -4,14 +4,14 @@ AITBC Monitor Service
""" """
import time import time
import logging
import json import json
from pathlib import Path from pathlib import Path
import psutil import psutil
from aitbc import get_logger, DATA_DIR
def main(): def main():
logging.basicConfig(level=logging.INFO) logger = get_logger('aitbc-monitor')
logger = logging.getLogger('aitbc-monitor')
while True: while True:
try: try:
@@ -21,14 +21,14 @@ def main():
logger.info(f'System: CPU {cpu_percent}%, Memory {memory_percent}%') logger.info(f'System: CPU {cpu_percent}%, Memory {memory_percent}%')
# Blockchain stats # Blockchain stats
blockchain_file = Path('/var/lib/aitbc/data/blockchain/aitbc/blockchain.json') blockchain_file = DATA_DIR / 'data/blockchain/aitbc/blockchain.json'
if blockchain_file.exists(): if blockchain_file.exists():
with open(blockchain_file, 'r') as f: with open(blockchain_file, 'r') as f:
data = json.load(f) data = json.load(f)
logger.info(f'Blockchain: {len(data.get("blocks", []))} blocks') logger.info(f'Blockchain: {len(data.get("blocks", []))} blocks')
# Marketplace stats # Marketplace stats
marketplace_dir = Path('/var/lib/aitbc/data/marketplace') marketplace_dir = DATA_DIR / 'data/marketplace'
if marketplace_dir.exists(): if marketplace_dir.exists():
listings_file = marketplace_dir / 'gpu_listings.json' listings_file = marketplace_dir / 'gpu_listings.json'
if listings_file.exists(): if listings_file.exists():

View File

@@ -5,16 +5,15 @@ Handles intelligent load distribution across global regions
import asyncio import asyncio
import json import json
import logging
from datetime import datetime, timedelta from datetime import datetime, timedelta
from pathlib import Path from pathlib import Path
from typing import Dict, Any, List, Optional from typing import Dict, Any, List, Optional
from fastapi import FastAPI, HTTPException from fastapi import FastAPI, HTTPException
from pydantic import BaseModel from pydantic import BaseModel
# Configure logging from aitbc import get_logger
logging.basicConfig(level=logging.INFO)
logger = logging.getLogger(__name__) logger = get_logger(__name__)
app = FastAPI( app = FastAPI(
title="AITBC Multi-Region Load Balancer", title="AITBC Multi-Region Load Balancer",

View File

@@ -5,7 +5,6 @@ Handles order matching, trade execution, and settlement
import asyncio import asyncio
import json import json
import logging
from collections import defaultdict, deque from collections import defaultdict, deque
from datetime import datetime from datetime import datetime
from pathlib import Path from pathlib import Path
@@ -14,9 +13,9 @@ from fastapi import FastAPI, HTTPException
from pydantic import BaseModel from pydantic import BaseModel
from contextlib import asynccontextmanager from contextlib import asynccontextmanager
# Configure logging from aitbc import get_logger
logging.basicConfig(level=logging.INFO)
logger = logging.getLogger(__name__) logger = get_logger(__name__)
@asynccontextmanager @asynccontextmanager
async def lifespan(app: FastAPI): async def lifespan(app: FastAPI):