Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from https://github.com/iron-io/iron_celery below:

iron-io/iron_celery: IronMQ broker and IronCache results store for Python's Celery project.

• Cloud message queue and caching services
• No servers
• No maintenance
• Scales effortlessly

Note: We recommend using virtualenv to avoid any dependency issues.

For IronMQ support, you'll need the iron_celery library:

$ pip install iron-celery

As well as an Iron.io account. Sign up for free at Iron.io.

First, you'll need to import the iron_celery library right after you import Celery, for example:

from celery import Celery
import iron_celery

celery = Celery('mytasks', broker='ironmq://', backend='ironcache://')

To use IronMQ, the broker URL should be in this format:

BROKER_URL = 'ironmq://ABCDEFGHIJKLMNOPQRST:ZYXK7NiynGlTogH8Nj+P9nlE73sq3@some_v3_host?connect_timeout=20'

where the URL format is:

ironmq://project_id:token@host?connect_timeout

The project_id and token are for your Iron.io account, you can find these in the Iron.io HUD. You must remember to include the "@" at the end.

You can set polling interval as following:

BROKER_TRANSPORT_OPTIONS={
    'polling_interval': 5.0
}

By default long-polling is enabled. To disable long-polling do the following:

BROKER_TRANSPORT_OPTIONS={
    'long_polling': False
}

Note: server closes connection after 30 seconds if there were no messages in queue during this interval.

Default max amount of messages is 10.

Note: If you want to increment/decrement amount of messages, you need to change value of CELERYD_PREFETCH_MULTIPLIER too or equal to zero:

BROKER_TRANSPORT_OPTIONS={
    'max_message_count': 50
},
CELERYD_PREFETCH_MULTIPLIER = 0

You can change the name of the default queue by using the following configuration:

from kombu import Exchange, Queue

CELERY_DEFAULT_QUEUE='new_queue_name',
CELERY_QUEUES=(
    Queue('new_queue_name', Exchange('new_queue_name'), routing_key='new_queue_name'),
)

The login credentials can also be set using the environment variables :envvar:IRON_TOKEN and :envvar:IRON_PROJECT_ID, which are set automatically if you use the IronMQ Heroku add-on. And in this case the broker url may only be:

The default cloud/region is AWS us-east-1. You can choose the IronMQ Rackspace/ORD cloud by changing the URL to::

ironmq://project_id:token@mq-rackspace-ord.iron.io

You can store results in IronCache with the same Iron.io credentials, just set the results URL with the same syntax as the broker URL, but changing the start to ironcache:

CELERY_RESULT_BACKEND = 'ironcache:://project_id:token@'

This will default to a cache named "Celery", if you want to change that:

ironcache://project_id:token@/awesomecache

Setup celery with Django as you normally would, but add import iron_celery and set the BROKER_URL to the URL's above. For example, at the top of your Django settings.py file:

# NOTE: these must go before djcelery.setup_loader() line
BROKER_URL = 'ironmq://project_id:token@'
CELERY_RESULT_BACKEND = 'ironcache://project_id:token@'

import djcelery
import iron_celery

djcelery.setup_loader()

You can test it by going through the First Steps with Django guide in the Celery documentation.

If you are using countdown or eta, make sure to use iron_mq_timeout option as well (otherwise message will be returned to the IronMQ queue before Celery will ack it).

iron_mq_timeout default value is 60 sec. You can change as following:

    BROKER_TRANSPORT_OPTIONS={
        'iron_mq_timeout': 90
    }

learn more about iron_mq_timeout here

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4