셀러리 'i'형식의 내부 오류입니다.

Question

셀러 리와 amqp를 사용하여 작업을 실행하려고하면 아래 오류가 발생합니다. 구성에 문제가 있습니다. 이 문제를 어떻게 해결할 수 있습니까? 결과를 저장

[2012-06-12 16:49:37,231: CRITICAL/MainProcess] Task core.tasks.sanity[c44c8058-46d1-48cd-a687-0481f5bd5ee5] INTERNAL ERROR: error("'i' format requires -2147483648 <= number <= 2147483647",) 
Traceback (most recent call last): 
    File "/nobackup/vivenara/pyenv/lib/python2.7/site-packages/celery/execute/trace.py", line 192, in trace_task 
    R = I.handle_error_state(task, eager=eager) 
    File "/nobackup/vivenara/pyenv/lib/python2.7/site-packages/celery/execute/trace.py", line 91, in handle_error_state 
    }[self.state](task, store_errors=store_errors) 
    File "/nobackup/vivenara/pyenv/lib/python2.7/site-packages/celery/execute/trace.py", line 114, in handle_failure 
    task.backend.mark_as_failure(req.id, exc, self.strtb) 
    File "/nobackup/vivenara/pyenv/lib/python2.7/site-packages/celery/backends/base.py", line 96, in mark_as_failure 
    traceback=traceback) 
    File "/nobackup/vivenara/pyenv/lib/python2.7/site-packages/celery/backends/base.py", line 229, in store_result 
    return self._store_result(task_id, result, status, traceback, **kwargs) 
    File "/nobackup/vivenara/pyenv/lib/python2.7/site-packages/celery/backends/amqp.py", line 121, in _store_result 
    "traceback": traceback}) 
    File "/nobackup/vivenara/pyenv/lib/python2.7/site-packages/kombu/connection.py", line 272, in _ensured 
    return fun(*args, **kwargs) 
    File "/nobackup/vivenara/pyenv/lib/python2.7/site-packages/celery/backends/amqp.py", line 97, in _publish_result 
    self._create_producer(task_id, connection).publish(meta) 
    File "/nobackup/vivenara/pyenv/lib/python2.7/site-packages/celery/backends/amqp.py", line 87, in _create_producer 
    self._create_binding(task_id)(connection.default_channel).declare() 
    File "/nobackup/vivenara/pyenv/lib/python2.7/site-packages/kombu/entity.py", line 386, in declare 
    self.queue_declare(nowait, passive=False) 
    File "/nobackup/vivenara/pyenv/lib/python2.7/site-packages/kombu/entity.py", line 408, in queue_declare 
    nowait=nowait) 
    File "/nobackup/vivenara/pyenv/lib/python2.7/site-packages/amqplib/client_0_8/channel.py", line 1376, in queue_declare 
    args.write_table(arguments) 
    File "/nobackup/vivenara/pyenv/lib/python2.7/site-packages/amqplib/client_0_8/serialization.py", line 378, in write_table 
    table_data.write(pack('>i', v)) 
error: 'i' format requires -2147483648 <= number <= 2147483647 

Answer 1

값 오버플 : 그것은 INT로 인식하면서

error: 'i' format requires -2147483648 <= number <= 2147483647 

BIGINT/경도 값은 AMQP 큐에 기록되고있다. 내가 생각하는 구성상의 문제는 아닙니다. 결과로 저장하려고 시도하는 가치는 무엇입니까? 결과 값이 무엇

return self._store_result(task_id, result, status, traceback, **kwargs) 

당신이 확인할 수 있습니다 내가 스택 추적에서 볼

?

def mark_as_failure(self, task_id, exc, traceback=None): 
     """Mark task as executed with failure. Stores the execption.""" 
     return self.store_result(task_id, exc, status=states.FAILURE, 
           traceback=traceback) 

이가 작업에서 발생한 예외가 될 수 없습니다 :

이

task.backend.mark_as_failure(req.id, exc, self.strtb) 

따라서이 경우에는이 결과로 EXC 반환 아마이 이상한 값 ...

편집입니다 bigint 상태 코드가 포함되어 있습니까?