rabin 3 months ago
parent
commit
fbc4fe22b3
5 changed files with 94 additions and 2 deletions
  1. 24 0
      check.py
  2. 19 0
      config/env/localhost.php
  3. 2 2
      config/setting.php
  4. 27 0
      daemon.py
  5. 22 0
      kill.py

+ 24 - 0
check.py

@@ -0,0 +1,24 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+import time
+import os
+timeSleep = 15
+
+def popen(command, bg=False):
+        string = command
+        if bg == True:
+                command = command + ' &'
+        process = os.popen(command)
+        output = process.read()
+        process.close()
+        return output
+
+# 定时执行进程
+def process():
+        command = 'python /www/api/daemon.py 1>/dev/null 2>&1 &'
+        check = 'ps -ef | grep daemon.py | grep -v grep | wc -l'
+        value = int(popen(check))
+        if value == 0:
+                popen(command)
+
+process()

+ 19 - 0
config/env/localhost.php

@@ -10,4 +10,23 @@ return array
         'user' => 'root',
         'pwd' => '123456',
     ),
+
+    'log' => array
+    (
+        /*
+        'type' => 'Pdo',
+        'pdo_type' => 'influxdb',
+        'host' => 'web-influx',
+        'port' => '8086',
+        'name' => 'api',
+        'user' => 'rabin',
+        'pwd' => 'ilyxddfe521',
+        */
+        'type' => 'Influxdb',
+        'host' => 'http://web-influx:8086',
+        'token' => 'w2u7KOsNxtaYBLb0EOmMpeZ4AvrDcZtpSbqcIrrO0WkQjhpQNmMm_B4WQeJtb6GpfrohOPA-SxaI0FmBSkYHhg==',
+        'name' => 'api',
+        'user' => 'shemic',
+        'precision' => 's',
+    ),
 );

+ 2 - 2
config/setting.php

@@ -32,7 +32,7 @@ return array
         'opt' => true,
         //'default' => array($env['db'], $env['db1'], 'type' => 'Pdo'),//读写分离
         'default' => $env['db'],
-        'db1' => $env['db'],
+        'log' => $env['log'],
 
         # 分区设置 
         'partition' => array
@@ -83,7 +83,7 @@ return array
         ),
     ),
     # 定义redis
-    //'redis' => array('host' => 'server-redis', 'port' => '6379', 'password' => 'dm_redis_123', 'expire' => 3600),
+    'redis' => array('host' => 'server-redis', 'port' => '6379', 'password' => 'dm_redis_123', 'expire' => 2147483647),
     
     # 根据api增加缓存
     /*

+ 27 - 0
daemon.py

@@ -0,0 +1,27 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+import time
+import os
+timeSleep = 15
+
+def popen(command, bg=False):
+        string = command
+        if bg == True:
+                command = command + ' &'
+        process = os.popen(command)
+        output = process.read()
+        process.close()
+        return output
+
+# 定时执行进程
+def process():
+        command = 'php /www/api/src/dai/seller/index.php \'{"l":"task.cron"}\' 1>/dev/null 2>&1 &'
+        check = 'ps -ef | grep task.cron | grep -v grep | wc -l'
+        i = 0
+        while 1:
+                value = int(popen(check))
+                if value == 0:
+                        popen(command)
+                time.sleep(timeSleep)
+
+process()

+ 22 - 0
kill.py

@@ -0,0 +1,22 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+import time
+import os
+
+def popen(command, bg=False):
+        string = command
+        if bg == True:
+                command = command + ' &'
+        process = os.popen(command)
+        output = process.read()
+        process.close()
+        return output
+
+# 定时执行进程
+def process():
+        check = 'ps -ef | grep task.cron | grep -v grep |awk \'{print $2}\''
+        value = int(popen(check))
+        if value:
+                popen('kill ' + str(value))
+
+process()