Commit 8384d8ed by Czémán Arnold

rework

parent 67944074
from os import getenv
from os import getenv, path
import subprocess
from kombu import Queue, Exchange
......@@ -8,6 +8,7 @@ from celery import Celery
HOSTNAME = gethostname()
AMQP_URI = getenv('AMQP_URI')
DNS_DB_DIR = getenv('DNS_DB_DIR', '/var/lib/circle/dnsdriver')
celery = Celery('dnsdriver', broker=AMQP_URI)
celery.conf.update(
......@@ -15,15 +16,15 @@ celery.conf.update(
CELERY_TASK_RESULT_EXPIRES=300,
CELERY_QUEUES=(
Queue(HOSTNAME + '.dns', Exchange(
'dnsdriver', type='direct'), routing_key='dnsdriver'),
'dnsdriver', type='direct'), routing_key='dnsdriver'),
)
)
@celery.task(name='firewall.reload_dns')
def t(data):
with open('/etc/sv/tinydns/root/data', 'w') as f:
def reload_dns(data):
with open(path.join(DNS_DB_DIR, 'data'), 'w') as f:
f.write('\n'.join(data))
process = subprocess.Popen(['make', '-C', '/etc/sv/tinydns/root'],
process = subprocess.Popen(['make', '-C', DNS_DB_DIR],
shell=False, stdin=subprocess.PIPE)
process.communicate('\n'.join(data) + '\n')
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment