You have to specify SQS in the broker URL: BROKER_URL = 'sqs://ABCDEFGHIJKLMNOPQRST:ZYXK7NiynGlTogH8Nj+P9nlE73sq3@' where the URL format is: sqs://aws_access_key_id:aws_secret_access_key@ you must remember have to specify IronMQ in the broker URL: BROKER_URL = 'ironmq://ABCDEFGHIJKLMNOPQRST:ZYXK7NiynGlTogH8Nj+P9nlE73sq3@' where the URL format is: ironmq://project_id:token@ you must remember to include the rarely used since it turns the asynchronous call into a synchronous one: >>> result.get(timeout=1) 8 In case the task raised an exception, get() will re-raise the exception, but you can override this

up using “bootsteps” — a dependency graph enabling fine grained control of the worker’s internals. 8 Chapter 2. Contents Celery Documentation, Release 3.1.25 Framework Integration Celery is easy to You have to specify SQS in the broker URL: BROKER_URL = 'sqs://ABCDEFGHIJKLMNOPQRST:ZYXK7NiynGlTogH8Nj+P9nlE73sq3@' where the URL format is: sqs://aws_access_key_id:aws_secret_access_key@ you must remember have to specify IronMQ in the broker URL: BROKER_URL = 'ironmq://ABCDEFGHIJKLMNOPQRST:ZYXK7NiynGlTogH8Nj+P9nlE73sq3@' where the URL format is: ironmq://project_id:token@ you must remember to include the

steps with Celery . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 8 1.4 Resources . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . Creating a click counter using carrot and celery . . . . . . . . . . . . . . . . . . . . . . . . 96 i 8 Frequently Asked Questions 101 8.1 General . . . . . . . . . . . . . . . . . . . . . . . . . . . . for it to finish: >>> result = add.delay(4, 4) >>> result.wait() # wait for and return the result 8 Simple! 4 Chapter 1. Getting Started Celery Documentation, Release 2.1.4 1.1.3 Features Mes- saging

Integration Celery is easy to integrate with web frameworks, some of them even have integration packages: 8 Chapter 2. Contents Celery Documentation, Release 4.2.1 Pyramid pyramid_celery Pylons celery-pylons You have to specify SQS in the broker URL: broker_url = 'sqs://ABCDEFGHIJKLMNOPQRST:ZYXK7NiynGlTogH8Nj+P9nlE73sq3@' where the URL format is: sqs://aws_access_key_id:aws_secret_access_key@ you must remember rarely used since it turns the asynchronous call into a synchronous one: >>> result.get(timeout=1) 8 In case the task raised an exception, get() will re-raise the exception, but you can override this

for it to finish: >>> result = add.delay(4, 4) >>> result.wait() # wait for and return the result 8 Simple! 4 Chapter 1. Getting Started Celery Documentation, Release 2.3.5 1.1.3 Features Mes- saging full documentation on how to create tasks and task classes is in the Tasks part of the user guide. 8 Chapter 1. Getting Started Celery Documentation, Release 2.3.5 1.3.2 Configuration Celery is configured result.get() # Waits until the task is done and returns the retval. 8 >>> result.result # direct access to result, doesn’t re-raise errors. 8 >>> result.successful() # returns True if the task didn’t end

for it to finish: >>> result = add.delay(4, 4) >>> result.wait() # wait for and return the result 8 Simple! 4 Chapter 1. Getting Started Celery Documentation, Release 2.0.3 (stable) 1.1.3 Features default name. Let’s create our celeryconfig.py. 1. Configure how we communicate with the broker: 8 Chapter 1. Getting Started Celery Documentation, Release 2.0.3 (stable) BROKER_HOST = "localhost" result.get() # Waits until the task is done and returns the retval. 8 >>> result.result # direct access to result, doesn’t re-raise errors. 8 >>> result.successful() # returns True if the task didn’t end

Integration Celery is easy to integrate with web frameworks, some of them even have integration packages: 8 Chapter 2. Contents Celery Documentation, Release 4.0.1 Pyramid pyramid_celery Pylons celery-pylons You have to specify SQS in the broker URL: broker_url = 'sqs://ABCDEFGHIJKLMNOPQRST:ZYXK7NiynGlTogH8Nj+P9nlE73sq3@' where the URL format is: sqs://aws_access_key_id:aws_secret_access_key@ you must remember rarely used since it turns the asynchronous call into a synchronous one: >>> result.get(timeout=1) 8 In case the task raised an exception, get() will re-raise the exception, but you can override this

not needed web2py web2py-celery Tornado tornado-celery For Django see First steps with Django. 8 Chapter 2. Contents Celery Documentation, Release 4.0.0 The integration packages aren’t strictly necessary You have to specify SQS in the broker URL: broker_url = 'sqs://ABCDEFGHIJKLMNOPQRST:ZYXK7NiynGlTogH8Nj+P9nlE73sq3@' where the URL format is: sqs://aws_access_key_id:aws_secret_access_key@ you must remember rarely used since it turns the asynchronous call into a synchronous one: >>> result.get(timeout=1) 8 In case the task raised an exception, get() will re-raise the exception, but you can override this

You have to specify SQS in the broker URL: broker_url = 'sqs://ABCDEFGHIJKLMNOPQRST:ZYXK7NiynGlTogH8Nj+P9nlE73sq3@' where the URL format is: sqs://aws_access_key_id:aws_secret_access_key@ you must remember rarely used since it turns the asynchronous call into a synchronous one: >>> result.get(timeout=1) 8 In case the task raised an exception, get() will re-raise the exception, but you can override this amqp://guest@localhost:5672// - ** ---------- . app: __main__:0x1012d8590 - ** ---------- . concurrency: 8 (processes) - ** ---------- . events: OFF (enable -E to monitor this worker) - ** ---------- -

You have to specify SQS in the broker URL: broker_url = 'sqs://ABCDEFGHIJKLMNOPQRST:ZYXK7NiynGlTogH8Nj+P9nlE73sq3@' where the URL format is: sqs://aws_access_key_id:aws_secret_access_key@ you must remember rarely used since it turns the asynchronous call into a synchronous one: >>> result.get(timeout=1) 8 In case the task raised an exception, get() will re-raise the exception, but you can override this amqp://guest@localhost:5672// - ** ---------- . app: __main__:0x1012d8590 - ** ---------- . concurrency: 8 (processes) - ** ---------- . events: OFF (enable -E to monitor this worker) - ** ---------- -