def process_customer_request(customer_data):
    # Khóa luồng trong 2-5 giây khi đợi AI trả về
    ai_insights = ai_service.analyze_customer(customer_data)
    database.update_customer_profile(customer_data, ai_insights)
    return generate_response(ai_insights)

import asyncio

async def process_customer_request(customer_data):
    # Gửi request AI không đồng bộ, song song với chuẩn bị database
    ai_task = asyncio.create_task(ai_service.analyze_customer_async(customer_data))
    db_task = asyncio.create_task(database.prepare_customer_update(customer_data))
    ai_insights, db_ready = await asyncio.gather(ai_task, db_task)
    await database.finalize_customer_update(db_ready, ai_insights)
    return generate_response(ai_insights)

import customer_pb2
customer = customer_pb2.Customer()
customer.id = "12345"
customer.first_name = "John"
# Giảm từ 60-80% kích thước dữ liệu so với JSON

class FeatureExtractor:
    def __init__(self):
        self.ai_required_fields = {
            'customer_analysis': ['age', 'income', 'transaction_count', 'last_activity'],
            'fraud_detection': ['amount', 'merchant', 'location', 'time_of_day'],
            'recommendation': ['purchase_history', 'preferences', 'demographics']
        }

    def extract_for_ai(self, full_record, ai_type):
        required = self.ai_required_fields.get(ai_type, [])
        return {field: full_record.get(field) for field in required}

extractor = FeatureExtractor()
lightweight_payload = extractor.extract_for_ai(customer_record, 'fraud_detection')
# Giảm tới 85% kích thước dữ liệu