1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
"""mysecureapp.py
Usage::
Generate Certificate:
```
mkdir ssl
openssl req -x509 -newkey rsa:4096 -keyout ssl/worker.key -out ssl/worker.pem -days 365
# remove passphrase
openssl rsa -in ssl/worker.key -out ssl/worker.key
Enter pass phrase for ssl/worker.key:
writing RSA key
```
cd examples/security
(window1)$ python mysecureapp.py worker -l INFO
(window2)$ cd examples/security
(window2)$ python
>>> from mysecureapp import boom
>>> boom.delay().get()
"I am a signed message"
"""
from celery import Celery
app = Celery(
'mysecureapp',
broker='redis://localhost:6379/0',
backend='redis://localhost:6379/0'
)
app.conf.update(
security_key='ssl/worker.key',
security_certificate='ssl/worker.pem',
security_cert_store='ssl/*.pem',
task_serializer='auth',
event_serializer='auth',
accept_content=['auth'],
result_accept_content=['json']
)
app.setup_security()
@app.task
def boom():
return "I am a signed message"
if __name__ == '__main__':
app.start()
|
