2.21

Author: TejeshKumarReddyCTR

\

@@ -0,0 +1,30 @@
+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
+

order-service/app.py

@@ -24,3 +24,7 @@ def send_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
+