A simple Django app to run celery tasks as processes.
Project description
=====
Process Engine
=====
Process Engine is used in conjunction with celery to create async process from
celery tasks via an API
Quick start
-----------
1. Add "processengine" to your INSTALLED_APPS setting like this::
INSTALLED_APPS = [
...
'processengine',
]
2. Include the router URLconf in your project urls.py like this::
from processengine.api import router as process_router
...
urlpatterns = [
url(r'^processengine/', include(process_router.urls)),
...
]
3. Add the PROCESS_MAP settings with your processes and the tasks to run like
so::
PROCESS_MAP = {
'my.process': [
'path.to.taskfile.task',
],
...
}
3. (Optional) Add settings for Slack Notifications. Note that it is an error to add a SLACK_WEBHOOK setting without also having the other settings below present.::
SLACK_WEBHOOK = "https://hooks.slack.com/services/T051CQH14/VWVRAAFA5/lPz2y84gM0JUoVllBow0Glcx"
SLACK_PROCESS_CHANNEL = "#Processes"
SLACK_PROCESS_USERNAME = "Someuser"
SLACK_PROCESS_EMOJI = ":ghost:"
SERVICE_NAME = "Someservice"
4. Run `python manage.py migrate` to create the processengine models.
5. to create a process run a POST to http://127.0.0.1:8000/processengine/process/
with the following data::
data = {
name: "my.process", # This is the name of your process set in PROCESS_MAP variable
context: {
"name": "value" # This is the data that you pass through to your task
}
}
Note: Your tasks need to conform to the pattern of json in and json out
Process Engine
=====
Process Engine is used in conjunction with celery to create async process from
celery tasks via an API
Quick start
-----------
1. Add "processengine" to your INSTALLED_APPS setting like this::
INSTALLED_APPS = [
...
'processengine',
]
2. Include the router URLconf in your project urls.py like this::
from processengine.api import router as process_router
...
urlpatterns = [
url(r'^processengine/', include(process_router.urls)),
...
]
3. Add the PROCESS_MAP settings with your processes and the tasks to run like
so::
PROCESS_MAP = {
'my.process': [
'path.to.taskfile.task',
],
...
}
3. (Optional) Add settings for Slack Notifications. Note that it is an error to add a SLACK_WEBHOOK setting without also having the other settings below present.::
SLACK_WEBHOOK = "https://hooks.slack.com/services/T051CQH14/VWVRAAFA5/lPz2y84gM0JUoVllBow0Glcx"
SLACK_PROCESS_CHANNEL = "#Processes"
SLACK_PROCESS_USERNAME = "Someuser"
SLACK_PROCESS_EMOJI = ":ghost:"
SERVICE_NAME = "Someservice"
4. Run `python manage.py migrate` to create the processengine models.
5. to create a process run a POST to http://127.0.0.1:8000/processengine/process/
with the following data::
data = {
name: "my.process", # This is the name of your process set in PROCESS_MAP variable
context: {
"name": "value" # This is the data that you pass through to your task
}
}
Note: Your tasks need to conform to the pattern of json in and json out
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
File details
Details for the file django-processengine-0.2.4.tar.gz
.
File metadata
- Download URL: django-processengine-0.2.4.tar.gz
- Upload date:
- Size: 9.7 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: Python-urllib/3.6
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | 43cb298ba2feab97b5b55fdf1f316dee839e25d3aeea036c11f12cd787de520c |
|
MD5 | 89bee1eedd27f0a521271151f59d1a36 |
|
BLAKE2b-256 | 669ff050fd641fac411c381c85f16a1080f920c5351c409f1f2b838273f106af |