|
# -*- coding: utf-8 -*-
import logging
from django.db import transaction
from django_six import CompatibilityBaseCommand, close_old_connections
from utils.redis.connect import r
logger = logging.getLogger('console')
class Command(CompatibilityBaseCommand):
def handle(self, *args, **options):
logger.info('Templet bak cmd is dealing')
while True:
# r.rpushjson('TEMPLET_CMD_KEY', {})
k, v = r.blpopjson('TEMPLET_CMD_KEY', 60)
if v:
close_old_connections()
logger.info(v)
with transaction.atomic():
pass
close_old_connections()
|