\

from flask import Flask, request, jsonify
import boto3
import os

app = Flask(__name__)

# Initialize SQS client
sqs = boto3.client('sqs', region_name='ap-south-1')  # Adjust region as needed
QUEUE_URL = os.environ.get('ORDER_QUEUE_URL', "")

@app.route('/order/order', methods=['POST'])
def send_message():
    data = request.get_json()
    message = data.get('message')

    if not message:
        return jsonify({'error': 'Message is required'}), 400

    try:
        response = sqs.send_message(
            QueueUrl=QUEUE_URL,
            MessageBody=message
        )
        return jsonify({'message_id': response['MessageId']}), 200
    except Exception as e:
        return jsonify({'error': str(e)}), 500
def health():
    return "Product service healthy", 200
root@TR-6K5RGY3:~/ecom# vim order-service/app.py