我在celeryconfig.py中设置了CELERY_RESULT_BACKEND ="amqp",但我得到:
>>> from tasks import add
>>> result = add.delay(3,5)
>>> result.ready()
Traceback (most recent call last):
File "<console>", line 1, in <module>
File "/djangoprojects/venv/local/lib/python2.7/site-packages/celery/result.py", line 105, in ready
return self.state in self.backend.READY_STATES
File "/djangoprojects/venv/local/lib/python2.7/site-packages/celery/result.py", line 184, in state
return self.backend.get_status(self.task_id)
File "/djangoprojects/venv/local/lib/python2.7/site-packages/celery/backends/base.py", line 414, in _is_disabled
raise NotImplementedError("No result backend configured. "
NotImplementedError: No result backend configured. Please see the documentation for more information.
从应用程序引擎的MapReduce控制台(myappid.appspot.com/mapreduce/status)我有input_reader定义映射缩减:mapreduce.input_readers.BlobstoreLineInputReader了我与一个普通Blob存储文件成功使用,但不以工作使用create_gs_key从云存储创建Blobkey.当我运行它时,我收到错误"BadReaderParamsError:找不到密钥THEKEY的blobinfo".输入阅读器检查是否存在BlobInfo.这有什么工作吗？不应该BlobInfo.get(BLOBKEY FROM CS)返回一个blobinfo？
要从谷歌云存储文件中获取blob_key,我运行这个:
from google.appengine.ext import blobstore
READ_PATH = '/gs/mybucket/myfile.json'
blob_key = blobstore.create_gs_key(READ_PATH)
print blob_key