[Feat] User 애플리케이션에 MongoDB(DocumentDB) 연결

.aws/ecs-task-definition.json

@@ -15,11 +15,35 @@
             ],
             "essential": true,
             "environment": [
+                {
+                    "name": "ENV",
+                    "value": "prod"
+                }
             ],
             "environmentFiles": [],
             "mountPoints": [],
             "volumesFrom": [],
             "secrets": [
+                {
+                    "name": "MONGODB_URI",
+                    "valueFrom": "arn:aws:ssm:ap-northeast-2:864981757354:parameter/xrpedia/documentdb/host"
+                },
+                {
+                    "name": "MONGODB_PORT",
+                    "valueFrom": "arn:aws:ssm:ap-northeast-2:864981757354:parameter/xrpedia/documentdb/port"
+                },
+                {
+                    "name": "MONGODB_DB",
+                    "valueFrom": "arn:aws:ssm:ap-northeast-2:864981757354:parameter/xrpedia/documentdb/dbname"
+                },
+                {
+                    "name": "MONGODB_USER",
+                    "valueFrom": "arn:aws:secretsmanager:ap-northeast-2:864981757354:secret:rds!cluster-b06771f3-3e07-4b6c-8e7b-b793cb7b498e-CcZIQG:username::"
+                },
+                {
+                    "name": "MONGODB_PASSWORD",
+                    "valueFrom": "arn:aws:secretsmanager:ap-northeast-2:864981757354:secret:rds!cluster-b06771f3-3e07-4b6c-8e7b-b793cb7b498e-CcZIQG:password::"
+                }
             ],
             "ulimits": [],
             "logConfiguration": {

pyproject.toml

@@ -15,6 +15,7 @@ boto3 = "^1.37.16"
 botocore = "^1.37.16"
 dotenv = "^0.9.9"
 httpx = "^0.28.1"
+pymongo = "^4.11.3"
 
 [build-system]
 requires = ["poetry-core"]

src/main/config/mongodb.py

@@ -0,0 +1,16 @@
+import os
+from dotenv import load_dotenv
+from pymongo import MongoClient
+
+load_dotenv()
+
+MONGO_URI = os.getenv("MONGODB_URI")
+MONGO_PORT = os.getenv("MONGODB_PORT")
+MONGO_DB = os.getenv("MONGODB_DB")
+MONGO_USER = os.getenv("MONGODB_USER")
+MONGO_PASSWORD = os.getenv("MONGODB_PASSWORD")
+
+
+def get_mongo_client():
+    client = MongoClient("mongodb://" + MONGO_USER + ":" + MONGO_PASSWORD + "@" + MONGO_URI + ":" + MONGO_PORT + "/" + MONGO_DB + "?retryWrites=true")
+    return client