shane0 · October 20, 2017 18:15 · caseymacphee · Oct 20, 2017 · shane0 · Oct 20, 2017
diff --git a/beat.bat b/beat.bat
 celery -A beat beat -l debug
diff --git a/beat.py b/beat.py
 from celery import Celery
 from web_tasks import Web

 celery = Celery()
 celery.config_from_object()

 @celery.task
 def web_task(site):
    print('running a web task')
    Web.open_url(site)
diff --git a/celeryconfig.py b/celeryconfig.py
 from celery.schedules import crontab

 # using rabbitmq
 broker_url = 'amqp://user:user@localhost:5672//'
 result_backend = 'amqp://user:user@localhost:5672//'

 beat_schedule = {
    'every-minute': {
        'task': 'worker.web_task',
        'schedule': crontab(minute='*/1'),
        'args': ['http://google.com'],
    },
 }
diff --git a/flower.bat b/flower.bat
 flower -A worker --port=5555
diff --git a/requirements.txt b/requirements.txt
 celery
 flower
diff --git a/web_tasks.py b/web_tasks.py
 # -*- coding: utf-8 -*-
 import webbrowser

 class Web:
    def __init__(self, url):
        self.url = url

    def open_url(url):
        webbrowser.open(url)
diff --git a/worker.bat b/worker.bat
 celery -A worker worker -l info
diff --git a/worker.py b/worker.py
 from celery import Celery
 from web_tasks import Web

 celery = Celery()
 celery.config_from_object('celeryconfig')

 @celery.task
 def web_task(site):
    print('running a web task')
    Web.open_url(site)
	from celery.schedules import crontab

	# using rabbitmq
	broker_url = 'amqp://user:user@localhost:5672//'
	result_backend = 'amqp://user:user@localhost:5672//'

	beat_schedule = {
	'every-minute': {
	'task': 'worker.web_task',
	'schedule': crontab(minute='*/1'),
	'args': ['http://google.com'],
	},
	}