tasks.py 332 B

123456789101112131415
  1. import urllib2
  2. from celery import task
  3. @task(ignore_result=True)
  4. def urlopen(url):
  5. print('Opening: %r' % (url, ))
  6. try:
  7. body = urllib2.urlopen(url).read()
  8. except Exception as exc:
  9. print('Exception for %r: %r' % (url, exc, ))
  10. return url, 0
  11. print('Done with: %r' % (url, ))
  12. return url, 1