eros/service/zeus/core.py

# -*- 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, id):
        command = Demeter.path + 'sync.py -t ' + table + ' -i ' + id
        Shell.popen("python3 " + command, bg=True)
        #self.sync(table)

    # 远程同步
    def sync(self, table, search={}):
        zeus = Demeter.config['zeus']['host']
        url = zeus + 'interface/sync'
        farm = Demeter.config['setting']['farm']
        data = Demeter.service('common').list(table, search=search)
        param = {}
        param['data'] = json.dumps(data)
        param['table'] = table
        param['farm'] = farm
        Demeter.curl(url, param, 'post')