Python 基础语法 15 rc脚本

3.5/3.6/3.7/3.8 rc脚本

3.5/3.6/3.7/3.8 rc脚本

rc脚本就是位于/etc/rc.d/init.d或者/etc/init.d/目录下的那些服务的启动脚本
现在用Python编写一个memcached的rc脚本

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
#!/usr/bin/env python
#coding:utf-8

from subprocess import Popen, PIPE   ##插入subprocess包两个模块 用于执行命令
import os
import sys

class Process(object):
    
    def __init__(self, name, program, args, workdir):  #实例化自动加载该方法 name命令名字 program 执行文件路径
        self.name = name                               #args 命令带的参数 workdir PID目录
        self.program = program                         #类的属性接受参数
        self.args = args
        self.workdir = workdir

#'''  自定义初始化方法 '''   
    def pidDir(self):
        if not os.path.exists(self.workdir):     ##判断自定义的PID目录var/tmp/memcached不存在，并创建进入该目录
            os.mkdir(self.workdir)
            os.chdir(self.workdir)

#'''  创建memcached的PID文件 '''
    def pidFile(self):                             ##返回memcachedPID的文件路径 var/tmp/memcached/memcached.pid
        return os.path.join(self.workdir,'%s.pid' %self.name)

#'''  把PID的数值写入PID文件中 '''
    def writePid(self):
        if self.pid:                               #判断pid存在并把pid写入var/tmp/memcached/memcached.pid中
            with open(self.pidFile(),'w') as fd:
                fd.write(str(self.pid))

#'''  定义start方法 '''
    def start(self):
        pid = self.getPid()
        if pid:
            print '%s 已经在跑了...' %self.name      #进程已经有了再此运行start会退出
            sys.exit()
        self.pidDir()                                #调用pidDir方法创建目录
        cmd = self.program + ' ' + self.args
        p = Popen(cmd, stdout=PIPE, shell=True)      #命令通过管道输出
        self.pid = p.pid                             #得到pid数值并定义对象公有属性 让weiterPid方法可以调用
        self.writePid()                              #调用writePid方法
        print '%s 启动成功...' %self.name

#''' 获得memcached的pid '''
    def getPid(self):
        p = Popen(['pidof',self.name],stdout=PIPE)   #获得pidof memcached命令来得到pid
        pid = p.stdout.read().strip()                #strip()去\n
        return pid

#'''  定义stop方法 '''
    def stop(self):
        pid = self.getPid()                               #调用getPid方法获取pid
        if pid:
            os.kill(int(pid), 15)                         #pid存在就傻掉pid
            if os.path.exists(self.pidFile()):            #再删除/tmp/memcached/memcached.pid
                os.remove(self.pidFile())
            print '%s 正在关闭...' %self.name

#'''  定义restart方法 '''
    def restart(self):
        self.stop()
        self.start()

#'''  定义status方法 '''
    def status(self):
        pid =self.getPid()
        if pid:
            print '%s 已经在运行中...' %self.name
        else:
            print '%s 没有运行...' %self.name

#'''  定义status方法  '''
    def helps(self):
        print '你可以按以下格式输入 %s {start|stop|restart|status}' %__file__ #__file__表示脚本本身

def main():       ##定义一个主函数
    
    name = 'memcached'
    prog = '/usr/bin/memcached'
    args = '-u nobody -p 11211 -c 1024 -m 64'
    wd = '/var/tmp/memcached'
    pm = Process(name = name, program = prog, args = args, workdir = wd)   ##实例化对象 并传参
    
    try:                   ##抓取脚本后是否带上选项,没有退出
        cmd = sys.argv[1]
    except IndexError:
        print '没有带上选项'
        sys.exit()

    if cmd == 'start':     ##判断选项来调用对象对应的方法
        pm.start()

    elif cmd == 'stop':
        pm.stop()

    elif cmd == 'restart':
        pm.restart()

    elif cmd == 'status':
        pm.status()

    else:
        pm.helps()


if __name__ == '__main__':   ##当自己执行自己会调用主函数 当被其他脚本作为模块时就不调用主函数
    main()

使用daemon方式（ 父进程就直接变成1 后台运行）来启动memcached脚本

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
#!/usr/bin/env python
#coding:utf-8

from subprocess import Popen, PIPE   ##插入subprocess包两个模块 用于执行命令
import os
import sys

class Process(object):
    
    args = {'PORT':11211,'USER':'memcached','MAXCONN':1024,'CACHESIZE':64,'OPTIONS':''}  #定义开始默认参数

    def __init__(self, name, program, workdir):  #实例化自动加载该方法 name命令名字 program 执行文件路径
        self.name = name                               #workdir PID目录
        self.program = program                         #类的属性接受参数
        self.workdir = workdir

#'''  读取memcached配置文件'''
    def readConf(self,f):                         #读取memcached配置文件 /ect/sysconfig/memcached内容
        with open(f) as fd:                       #并以该文件内容为最新的参数以字典形式返回
            lines = fd.readlines()
            return dict([i.strip().replace('"','').split('=') for i in lines]) #strip去空格 replace去” split去=

#''''  替换默认参数'''
    def replaceArgs(self):
        conf = self.readConf('/etc/sysconfig/memcached')  #/ect/sysconfig/memcached内的参数替换掉默认参数并返回
        if 'PORT' in conf:
            self.args['PORT'] = conf['PORT']
        if 'USER' in conf:
            self.args['USER'] = conf['USER']
        if 'MAXCONN' in conf:
            self.args['MAXCONN'] = conf['MAXCONN']
        if 'CACHESIZE' in conf:
            self.args['CACHESIZE'] = conf['CACHESIZE']
        options = ['-p',self.args['PORT'],
                   '-u',self.args['USER'],
                   '-m',self.args['MAXCONN'],
                   '-c',self.args['CACHESIZE'] ]
        os.system('chown %s %s' %(self.args['USER'], self.workdir))  #更改var/tmp/memcached权限 来创建该目录
        return options

#'''  自定义初始化方法 '''   
    def pidDir(self):
        if not os.path.exists(self.workdir):     ##判断自定义的PID目录var/tmp/memcached不存在，并创建进入该目录
            os.mkdir(self.workdir)
            os.chdir(self.workdir)

#'''  创建memcached的PID文件 '''
    def pidFile(self):                             ##返回memcachedPID的文件路径 var/tmp/memcached/memcached.pid
        return os.path.join(self.workdir,'%s.pid' %self.name)

#'''  把PID的数值写入PID文件中 '''
    def writePid(self):
        if self.pid:                               #判断pid存在并把pid写入var/tmp/memcached/memcached.pid中
            with open(self.pidFile(),'w') as fd:
                fd.write(str(self.pid))

#'''  定义start方法 '''
    def start(self):
        pid = self.getPid()
        if pid:
            print '%s 已经在跑了...' %self.name      #进程已经有了再此运行start会退出
            sys.exit()
        self.pidDir()                                #调用pidDir方法创建目录
        cmd = [self.program] + self.replaceArgs() + ['-d','-P',self.pidFile()]
        print cmd                                    #打印出命令内容
        p = Popen(cmd, stdout=PIPE)                  #命令通过管道输出
        #self.pid = p.pid                            #得到pid数值并定义对象公有属性 让weiterPid方法可以调用
        #self.writePid()                             #调用writePid方法 -P会自动把pid写进文件中因此不需要这两句
        print '%s 启动成功...' %self.name

#''' 获得memcached的pid '''
    def getPid(self):
        p = Popen(['pidof',self.name],stdout=PIPE)   #获得pidof memcached命令来得到pid
        pid = p.stdout.read().strip()                #strip()去\n
        return pid

#'''  定义stop方法 '''
    def stop(self):
        pid = self.getPid()                               #调用getPid方法获取pid
        if pid:
            os.kill(int(pid), 15)                         #pid存在就傻掉pid
            if os.path.exists(self.pidFile()):            #再删除/tmp/memcached/memcached.pid
                os.remove(self.pidFile())
            print '%s 正在关闭...' %self.name

#'''  定义restart方法 '''
    def restart(self):
        self.stop()
        self.start()

#'''  定义status方法 '''
    def status(self):
        pid =self.getPid()
        if pid:
            print '%s 已经在运行中...' %self.name
        else:
            print '%s 没有运行...' %self.name

#'''  定义status方法  '''
    def helps(self):
        print '你可以按以下格式输入 %s {start|stop|restart|status}' %__file__ #__file__表示脚本本身

def main():       ##定义一个主函数
    
    name = 'memcached'
    prog = '/usr/bin/memcached'
    wd = '/var/tmp/memcached'
    pm = Process(name = name, program = prog, workdir = wd)   ##实例化对象 并传参
    
    try:                   ##抓取脚本后是否带上选项,没有退出
        cmd = sys.argv[1]
    except IndexError:
        print '没有带上选项'
        sys.exit()

    if cmd == 'start':     ##判断选项来调用对象对应的方法
        pm.start()

    elif cmd == 'stop':
        pm.stop()

    elif cmd == 'restart':
        pm.restart()

    elif cmd == 'status':
        pm.status()

    else:
        pm.helps()


if __name__ == '__main__':   ##当自己执行自己会调用主函数 当被其他脚本作为模块时就不调用主函数
    main()

扫一扫，分享到微信

微信分享二维码

tag:

    缺失模块。
    1、请确保node版本大于6.2
    2、在博客根目录（注意不是yilia根目录）执行以下命令：
    npm i hexo-generator-json-content --save

    3、在根目录_config.yml里添加配置： 

      jsonContent:
    meta: false
    pages: false
    posts:
      title: true
      date: true
      path: true
      text: false
      raw: false
      content: false
      slug: false
      updated: false
      comments: false
      link: false
      permalink: false
      excerpt: false
      categories: false
      tags: true

欢迎光临<br><br>本博客是用来记录学习Linux Python Shell和Perl<br>谢谢大家