fix(logger): miss log

Author: duanhongyi

rootfs/api/models/gateway.py

@@ -25,6 +25,17 @@ class Gateway(AuditedModel):
     name = models.CharField(max_length=63, db_index=True)
     ports = models.JSONField(default=list)
 
+    def log(self, message, level=logging.INFO):
+        """Logs a message in the context of this service.
+
+        This prefixes log messages with an application "tag" that the customized
+        drycc-logspout will be on the lookout for.  When it's seen, the message-- usually
+        an application event of some sort like releasing or scaling, will be considered
+        as "belonging" to the application instead of the controller and will be handled
+        accordingly.
+        """
+        logger.log(level, "[{}]: {}".format(self.app.id, message))
+
     def add(self, port, protocol):
         # check port
         if not self._check_port(port, protocol):
@@ -126,8 +137,8 @@ def delete(self, *args, **kwargs):
         try:
             self.scheduler().gateways.delete(self.app.id, self.name, ignore_exception=False)
         except KubeException:
-            logger.log(
-                msg='Kubernetes gateway cannot be deleted: {}'.format(self.name),
+            self.log(
+                'Kubernetes gateway cannot be deleted: {}'.format(self.name),
                 level=logging.ERROR,
             )
         return super().delete(*args, **kwargs)
@@ -225,6 +236,17 @@ def current_rules(self):
             return self.rules["canary"]
         return self.rules["stable"]
 
+    def log(self, message, level=logging.INFO):
+        """Logs a message in the context of this service.
+
+        This prefixes log messages with an application "tag" that the customized
+        drycc-logspout will be on the lookout for.  When it's seen, the message-- usually
+        an application event of some sort like releasing or scaling, will be considered
+        as "belonging" to the application instead of the controller and will be handled
+        accordingly.
+        """
+        logger.log(level, "[{}]: {}".format(self.app.id, message))
+
     def check_rules(self):
         service = self.app.service_set.filter(
             procfile_type=self.procfile_type).first()
@@ -297,8 +319,8 @@ def delete(self, *args, **kwargs):
             k8s_route = getattr(self.scheduler(), self.kind.lower())
             k8s_route.delete(self.app.id, self.name, ignore_exception=False)
         except KubeException:
-            logger.log(
-                msg='Kubernetes {} cannot be deleted: {}'.format(self.kind.lower(), self.name),
+            self.log(
+                'Kubernetes {} cannot be deleted: {}'.format(self.kind.lower(), self.name),
                 level=logging.ERROR,
             )
         return super().delete(*args, **kwargs)

rootfs/api/models/tls.py

@@ -106,8 +106,8 @@ def refresh_certificate_to_k8s(self):
                     version = data["metadata"]["resourceVersion"]
                     self.scheduler().certificate.put(namespace, name, hosts, version)
                 else:
-                    logger.log(
-                        msg="certificate {} does not exist".format(namespace), level=logging.INFO)
+                    self.log(
+                        "certificate {} does not exist".format(namespace), level=logging.INFO)
                     self.scheduler().certificate.create(namespace, name, hosts)
             else:
                 self.log("skip creating certificate, no domain name set", logging.WARNING)

rootfs/requirements.txt

@@ -27,6 +27,4 @@ hiredis==2.3.2
 django_redis==5.4.0
 dj-database-url==2.1.0
 social-auth-app-django==5.4.1
-python-jose==3.3.0
-Authlib==1.3.0
 kubernetes==29.0.0