nezaidu

curl -X POST \
-H "Authorization: key= YOUR-API-KEY" \
-H "Content-Type: application/json" \
-d '{ 
"registration_ids": [ 
"YOUR-GCM-REGISTRATION-ID"
], 
"data": { 
"message": "Hello Message"
},

nezaidu

from concurrent.futures import ThreadPoolExecutor
from functools import partial, wraps
import time

import tornado.ioloop
import tornado.web


EXECUTOR = ThreadPoolExecutor(max_workers=4)

nezaidu

# tested with celery[redis]==3.1.17

# to run with default configuration -- tasks will take 14 seconds to complete the 20 tasks in start_all() below

celery worker -A cluster_project.celery_app -Q tester -lINFO --concurrency=4

# to run with -Ofair -- tasks will take 10 seconds to complete

celery worker -A cluster_project.celery_app -Q tester -lINFO --concurrency=4 -Ofair