feat: apply hint option to query

Signed-off-by: Jongmin Kim <whdalsrnt@megazone.com>

Author: Jongmin Kim

src/spaceone/core/model/mongo_model/__init__.py

@@ -679,6 +679,7 @@ def query(
         unwind=None,
         reference_filter=None,
         target=None,
+        hint=None,
         **kwargs,
     ):
         filter = filter or []
@@ -706,6 +707,9 @@ def query(
             try:
                 vos = cls._get_target_objects(target).filter(_filter)
 
+                if hint:
+                    vos = vos.hint(hint)
+
                 if len(_order_by) > 0:
                     vos = vos.order_by(*_order_by)
 
@@ -1119,7 +1123,7 @@ def _make_aggregate_rules(cls, aggregate):
         return _aggregate_rules
 
     @classmethod
-    def _stat_aggregate(cls, vos, aggregate, page, allow_disk_use, return_type):
+    def _stat_aggregate(cls, vos, aggregate, page, hint, allow_disk_use, return_type):
         result = {}
         pipeline = []
         _aggregate_rules = cls._make_aggregate_rules(aggregate)
@@ -1145,9 +1149,16 @@ def _stat_aggregate(cls, vos, aggregate, page, allow_disk_use, return_type):
 
         if allow_disk_use:
             _LOGGER.debug(f"[_stat_aggregate] allow_disk_use: {allow_disk_use}")
-            cursor = vos.aggregate(pipeline, allowDiskUse=True)
+
+            if hint:
+                cursor = vos.aggregate(pipeline, hint=hint, allowDiskUse=True)
+            else:
+                cursor = vos.aggregate(pipeline, allowDiskUse=True)
         else:
-            cursor = vos.aggregate(pipeline)
+            if hint:
+                cursor = vos.aggregate(pipeline, hint=hint)
+            else:
+                cursor = vos.aggregate(pipeline)
 
         if return_type == "cursor":
             return cursor
@@ -1158,6 +1169,7 @@ def _stat_aggregate(cls, vos, aggregate, page, allow_disk_use, return_type):
     @classmethod
     def _stat_distinct(cls, vos, distinct, page):
         result = {}
+
         values = vos.distinct(distinct)
 
         try:
@@ -1187,6 +1199,7 @@ def stat(
         page=None,
         reference_filter=None,
         target="SECONDARY_PREFERRED",
+        hint=None,
         allow_disk_use=False,
         return_type="dict",
         **kwargs,
@@ -1205,7 +1218,7 @@ def stat(
 
             if aggregate:
                 return cls._stat_aggregate(
-                    vos, aggregate, page, allow_disk_use, return_type
+                    vos, aggregate, page, hint, allow_disk_use, return_type
                 )
 
             elif distinct: