1234567891011121314151617181920212223242526272829303132333435 |
- # -*- coding: utf-8 -*-
- from demeter.core import *
- class Core(object):
- def init(self):
- # 注册
- zeus = Demeter.config['zeus']['host']
- url = zeus + 'interface/init'
- farm = Demeter.config['setting']['farm']
- ip = '192.168.33.10'
- data = Demeter.curl(url, {'id':farm,'ip':ip}, 'post')
- # 保存需要同步的数据,定时同步
- def save(self):
- pass
- # 实时同步
- def rsync(self, table):
- command = Demeter.path + 'sync.py -t ' + table
- Shell.popen("python3 " + command, bg=True)
- #self.sync(table)
- # 远程同步
- def sync(self, table):
- zeus = Demeter.config['zeus']['host']
- url = zeus + 'interface/sync'
- farm = Demeter.config['setting']['farm']
- data = Demeter.service('common').list(table)
- param = {}
- param['data'] = json.dumps(data)
- param['table'] = table
- param['farm'] = farm
- Demeter.curl(url, param, 'post')
|