cron: log basic resource usage summary (#89037)

@@ -129,1 +129,4 @@
         CronJob.log('running jobs: %r' % sorted([x.name or x for x in jobs]))
+        import wcs.sql
+
+        queries = []

@@ -76,3 +76,3 @@
         os.makedirs(log_dir, exist_ok=True)
         with open(os.path.join(log_dir, 'cron.log-%s' % now.strftime('%Y%m%d')), 'a+') as fd:
-            fd.write('%s [%s] %s\n' % (now.isoformat(), os.getpid(), message))
+            fd.write('%s [%s] %s\n' % (now.isoformat(), os.getpid(), message.replace('\n', ' ')))

@@ -130,0 +134,4 @@
+        import wcs.sql
+
+        if get_publisher().get_site_option('cron-log-level') == 'debug':
+            wcs.sql.LoggingCursor.queries_log_function = CronJob.log_sql

@@ -142,0 +154,4 @@
+        process_end = time.process_time()
+        memory_end = psutil.Process().memory_info().rss / (1024 * 1024)
+        CronJob.log(
+            'resource usage summary: CPU time: %.2fs / Memory: %.2fM / SQL queries: %s'

@@ -99,0 +103,4 @@
+    queries_log_function = None
+
+    def execute(self, query, vars=None):
+        LoggingCursor.queries_count += 1

@@ -99,0 +105,4 @@
+    def execute(self, query, vars=None):
+        LoggingCursor.queries_count += 1
+        if self.queries_log_function:
+            self.queries_log_function(query)

@@ -99,0 +107,4 @@
+        if self.queries_log_function:
+            self.queries_log_function(query)
+        if self.queries is not None:
+            self.queries.append(query)