开发者

Parsing keepalived.conf, translate to json

开发者 https://www.devze.com 2023-02-27 01:28 出处:网络
What would be the (python preferred) best way to parse the keepalived.conf format and return it to json ? I\'d like to automate the adding/removing of virtual and real servers.

What would be the (python preferred) best way to parse the keepalived.conf format and return it to json ? I'd like to automate the adding/removing of virtual and real servers.

My first guess is pyparsing, following a few answers from stackoverflow, but I can't get it to work !

The format of keepalived.conf is like this :

virtual_server 192.168.1.1 80
{
lb_algo wrr开发者_开发知识库
lb_kind DR
protocol TCP
ha_suspend
delay_loop 10

    # server-01
real_server 192.168.1.100 80
{
    weight 100
    inhibit_on_failure
    TCP_CHECK
    {
        connect_port 80
        connect_timeout 5
    }
}
# server-02
real_server 192.168.1.101 80
{
    weight 100
    inhibit_on_failure
    TCP_CHECK
    {
        connect_port 80
        connect_timeout 5
    }
  }
}

Thanks in advance !


Here is a rough first pass at parsing this data:

from pyparsing import *

# basic punctuation - useful in parsing, but suppress from results    
LBRACE,RBRACE = map(Suppress, "{}")

# some simple terminals
ipv4_address = Regex(r"\d{1,3}(\.\d{1,3}){3}")
ipv6_address = Regex(r"[0-9a-fA-F:]+")
ip_address = ipv4_address | ipv6_address
integer = Word(nums).setParseAction(lambda t:int(t[0]))

# config parameters that take 0 or 1 arguments    
config_param0 = oneOf("ha_suspend inhibit_on_failure")
config_param1 = oneOf("""lb_algo b_kind protocol delay_loop weight 
                         connect_port connect_timeout""")
param_arg = integer | Word(alphanums)
config_param = Group(config_param1 + param_arg) | config_param0

# definitions for a real_server    
tcp_check = ("TCP_CHECK" + LBRACE + 
                OneOrMore(config_param) +
                RBRACE)

real_defn = Group("real_server" + 
                ip_address("rip_address") + 
                integer("rport") + LBRACE +
                ZeroOrMore(config_param)("params") + 
                tcp_check("tcp_check") + RBRACE
                )

# definiton for a virtual_server                    
virtual_defn = ("virtual_server" + 
                ip_address("vip_address") + 
                integer("vport") + LBRACE +
                ZeroOrMore(config_param)("params") + 
                OneOrMore(real_defn)("real_defns") + RBRACE
                )

# skip over comments
comment = '#' + restOfLine
virtual_defn.ignore(comment)

# parse the input string and dump out the pieces
confdata = virtual_defn.parseString(conf)
print confdata.dump()
for rip in confdata.real_defns:
    print
    print rip.dump()

Prints the following:

['virtual_server', '192.168.1.1', 80, ['lb_algo', 'wrrl'], ...
- params: [['lb_algo', 'wrrl'], ['b_kind', 'DR'], ['protocol', 'TCP'], 
            'ha_suspend', ['delay_loop', 10]]
- real_defns: [['real_server', '192.168.1.100', 80, ['weight', ...
- vip_address: 192.168.1.1
- vport: 80

['real_server', '192.168.1.100', 80, ['weight', 100], 'inhibit_on_fa...
- params: [['weight', 100], 'inhibit_on_failure']
- rip_address: 192.168.1.100
- rport: 80
- tcp_check: ['TCP_CHECK', ['connect_port', 80], ['connect_timeout', 5]]

['real_server', '192.168.1.101', 80, ['weight', 100], 'inhibit_on_fai...
- params: [['weight', 100], 'inhibit_on_failure']
- rip_address: 192.168.1.101
- rport: 80
- tcp_check: ['TCP_CHECK', ['connect_port', 80], ['connect_timeout', 5]]
0

精彩评论

暂无评论...
验证码 换一张
取 消