tasks.py 文件源码

def cron_add_pcbaby_tasks_weekly():
    """
        ???pcbaby??????????????
    """
    now = datetime.utcnow()
    seeds = CrawlerSeeds.objects.filter()

    queue = settings.TASK_QUEUE_MAPPER.get("seed", {}).get("pcbaby")

    for seed in seeds:
        seed.modified_on = now
        seed.last_crawl_on = now
        seed.status = "crawling"
        seed.save()

        print "Going to put task: %s to queue: %s" % (seed.id, queue)
        rop.add_task_queue(queue, str(seed.id))