diff --git a/apps/compliance-service/main.py b/apps/compliance-service/main.py
index 74580275..7b2cc645 100755
--- a/apps/compliance-service/main.py
+++ b/apps/compliance-service/main.py
@@ -5,7 +5,6 @@ Handles KYC/AML, regulatory compliance, and monitoring
 
 import asyncio
 import json
-import logging
 from datetime import datetime, timedelta
 from pathlib import Path
 from typing import Dict, Any, List, Optional
@@ -13,9 +12,9 @@ from fastapi import FastAPI, HTTPException
 from pydantic import BaseModel
 from contextlib import asynccontextmanager
 
-# Configure logging
-logging.basicConfig(level=logging.INFO)
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 
 @asynccontextmanager
 async def lifespan(app: FastAPI):
diff --git a/apps/exchange-integration/main.py b/apps/exchange-integration/main.py
index 4d8c8f59..659a0a55 100755
--- a/apps/exchange-integration/main.py
+++ b/apps/exchange-integration/main.py
@@ -5,7 +5,6 @@ Handles real exchange connections and trading operations
 
 import asyncio
 import json
-import logging
 from datetime import datetime
 from pathlib import Path
 from typing import Dict, Any, List, Optional
@@ -13,9 +12,9 @@ import aiohttp
 from fastapi import FastAPI, HTTPException
 from pydantic import BaseModel
 
-# Configure logging
-logging.basicConfig(level=logging.INFO)
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 
 app = FastAPI(
     title="AITBC Exchange Integration Service",
diff --git a/apps/global-ai-agents/main.py b/apps/global-ai-agents/main.py
index ab6065bd..5c2ea31e 100755
--- a/apps/global-ai-agents/main.py
+++ b/apps/global-ai-agents/main.py
@@ -5,16 +5,15 @@ Handles cross-chain and cross-region AI agent communication with global optimiza
 
 import asyncio
 import json
-import logging
 from datetime import datetime, timedelta
 from pathlib import Path
 from typing import Dict, Any, List, Optional
 from fastapi import FastAPI, HTTPException
 from pydantic import BaseModel
 
-# Configure logging
-logging.basicConfig(level=logging.INFO)
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 
 app = FastAPI(
     title="AITBC Global AI Agent Communication Service",
diff --git a/apps/global-infrastructure/main.py b/apps/global-infrastructure/main.py
index 7c616e41..6a43707f 100755
--- a/apps/global-infrastructure/main.py
+++ b/apps/global-infrastructure/main.py
@@ -5,16 +5,15 @@ Handles multi-region deployment, load balancing, and global optimization
 
 import asyncio
 import json
-import logging
 from datetime import datetime, timedelta
 from pathlib import Path
 from typing import Dict, Any, List, Optional
 from fastapi import FastAPI, HTTPException
 from pydantic import BaseModel
 
-# Configure logging
-logging.basicConfig(level=logging.INFO)
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 
 app = FastAPI(
     title="AITBC Global Infrastructure Service",
diff --git a/apps/monitor/monitor.py b/apps/monitor/monitor.py
index a9496d20..9b8d1275 100644
--- a/apps/monitor/monitor.py
+++ b/apps/monitor/monitor.py
@@ -4,14 +4,14 @@ AITBC Monitor Service
 """
 
 import time
-import logging
 import json
 from pathlib import Path
 import psutil
 
+from aitbc import get_logger, DATA_DIR
+
 def main():
-    logging.basicConfig(level=logging.INFO)
-    logger = logging.getLogger('aitbc-monitor')
+    logger = get_logger('aitbc-monitor')
     
     while True:
         try:
@@ -21,14 +21,14 @@ def main():
             logger.info(f'System: CPU {cpu_percent}%, Memory {memory_percent}%')
             
             # 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():
                 with open(blockchain_file, 'r') as f:
                     data = json.load(f)
                     logger.info(f'Blockchain: {len(data.get("blocks", []))} blocks')
             
             # Marketplace stats
-            marketplace_dir = Path('/var/lib/aitbc/data/marketplace')
+            marketplace_dir = DATA_DIR / 'data/marketplace'
             if marketplace_dir.exists():
                 listings_file = marketplace_dir / 'gpu_listings.json'
                 if listings_file.exists():
diff --git a/apps/multi-region-load-balancer/main.py b/apps/multi-region-load-balancer/main.py
index 62f9b44d..d1d8abce 100755
--- a/apps/multi-region-load-balancer/main.py
+++ b/apps/multi-region-load-balancer/main.py
@@ -5,16 +5,15 @@ Handles intelligent load distribution across global regions
 
 import asyncio
 import json
-import logging
 from datetime import datetime, timedelta
 from pathlib import Path
 from typing import Dict, Any, List, Optional
 from fastapi import FastAPI, HTTPException
 from pydantic import BaseModel
 
-# Configure logging
-logging.basicConfig(level=logging.INFO)
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 
 app = FastAPI(
     title="AITBC Multi-Region Load Balancer",
diff --git a/apps/trading-engine/main.py b/apps/trading-engine/main.py
index aa28ebd8..554b33a8 100755
--- a/apps/trading-engine/main.py
+++ b/apps/trading-engine/main.py
@@ -5,7 +5,6 @@ Handles order matching, trade execution, and settlement
 
 import asyncio
 import json
-import logging
 from collections import defaultdict, deque
 from datetime import datetime
 from pathlib import Path
@@ -14,9 +13,9 @@ from fastapi import FastAPI, HTTPException
 from pydantic import BaseModel
 from contextlib import asynccontextmanager
 
-# Configure logging
-logging.basicConfig(level=logging.INFO)
-logger = logging.getLogger(__name__)
+from aitbc import get_logger
+
+logger = get_logger(__name__)
 
 @asynccontextmanager
 async def lifespan(app: FastAPI):