kombu

    0열

    1답변

    단위 테스트를위한 메모리 내 전송을 올바르게 사용하는 방법

    메시지를 큐에 생성하고 메시지가 올바르게 소비되고 응용 프로그램에서 처리되는지 확인하기 위해 테스트를 작성하려고합니다. 저는 kombu 라이브러리와 특히 메모리 내 전송 구현을 가지고 놀고 있습니다. 여전히 나는 작동하지 않으며, 생성 된 메시지가 소비됩니다. 사람이 생산하고 메모리 내 메시지를 소모하는 간단한 단위 테스트를 제공 할 수 있는지 내 질문은,
    python kombu 2016-07-01

    3열

    1답변

    pytest에서 연결 클래스 모의

    나는 실제 rabbitmq 서비스를 사용하지 않고 테스트하고 싶은 kombu.ConsumerProducerMixin에서 상속받은 클래스가 있습니다. from unittest.mock import Mock, patch from aggregator import Aggregator @patch('kombu.connection.Connection') de
    python unit-testing mocking rabbitmq kombu 2017-03-08

    0열

    1답변

    kombu에서 (u'json ',)에 인코더가 설치되지 않았습니다.

    어딘가에 단계가 빠져 있다고 생각하지만 주위를 둘러 보았고 찾을 수 없었습니다. 셀러리 작업을 실행할 때 get_task.delay(args)을 호출하면이 오류 메시지 no encoder installed for (u'json',)이 발생합니다. 내 자신의 사용자 지정 serialization을 가지고 있다고 가정합니까? settings.py CELERY_
    django celery kombu 2017-10-06

    0열

    1답변

    Mac OS 10.9.5에서 kombu로 런타임 오류가 발생했습니다.

    OS X 10.9.5에서 Python에서 Celery를 사용하려고하면 이상한 오류가 발생합니다. 이것은 이전에 사용되었지만 kombu.five를 가져올 때 C 라이브러리를 사용하지 못했습니다. ~$ python Python 2.7.8 (default, Aug 24 2014, 21:26:19) [GCC 4.2.1 Compatible Apple LLVM 5
    python macos homebrew kombu 2014-10-10

    0열

    1답변

    rabbitmq 용 kombu로 RPC 클라이언트 구현 및 직접 회신 기능

    kombu를 사용하여 토끼와 함께 사용할 rabbitmq's direct reply-to feature을 사용하고 싶습니다. kombu로 구현할 방법을 찾을 수 없습니다. . 클라이언트는 메시지를 만들기 전에 'amq.rabbitmq.reply-to'대기열에서 소비해야하며 제작자와 고객은 동일한 채널을 사용해야합니다. 클라이언트가 스레드 환경에서 작성되기
    python rabbitmq rpc kombu 2017-05-14

    1열

    1답변

    셀 로우를 시작할 때 'Queue'라는 모듈이 없습니다.

    최근에 파이썬 3.3.5로 업그레이드되었습니다. 나는 거의 모든 것이 올바르게 작동하고 있지만 셀러리/콩부는 꽤 불행한 것 같다. kombu에는 버그가있을 수 있지만 확실하지 않습니다. 나는 그것이 내가 빠진 것이기를 희망한다. 어떤 도움이라도 대단히 감사하겠습니다. 감사. (vgmdash33-env)The-Judge:vgmdash joshuafialkof
    django celery kombu 2014-10-13

    0열

    1답변

    셀러리 꽃은 작업자를 종료 할 수 있지만 다시 시작할 수 없습니다.

    콘돔 장고 셀러리 셀러리를 설치했습니다 & 꽃. 셀러리 꽃은 잘 감시 중입니다. 작업자를 종료 할 수는 있지만 다시 시작할 수는 없습니다. 꽃 응답 : [I 140903 15:49:12 web:1856] 200 GET/(127.0.0.1) 77.49ms [I 140903 15:49:13 web:1856] 304 GET /static/img/glyphico
    python django celery kombu flower 2014-09-03

    3열

    1답변

    Kombu + RabbitMQ : 큐가 비어 있는지 확인하십시오.

    아키텍처 DB 레코드가있는 시스템을 고려하십시오. 각 레코드는 live 또는 expired 상태 일 수 있습니다. live 레코드는 외부 소프트웨어 모듈을 사용하여 주기적으로 처리해야합니다. 나는 Kombu와 RabbitMQ의 고전적인 생산자 - 소비자 아키텍처를 사용하여 이것을 해결했다. 생산자는 몇 초마다 DB에서 레코드를 가져오고 소비자가 처리합니다.
    python rabbitmq kombu 2016-11-07

    1열

    1답변

    다시마 - 형식 오류 : 구조체() 인수 1이 아닌

    유니 코드 지금 언젠가 Kombu을 사용하고, 문자열이어야합니다 - 나는 배치를위한 새로운 기계를 readied 때 오늘, 나는 kombu에서 import에 TypeError 무엇입니까 : >>> import kombu >>> from kombu import Connection, Exchange, Queue, Producer Traceback (most
    python-2.7 typeerror kombu 2016-09-20

    3열

    2답변

    Kombu는 여러 소비자에게 게시 및 구독을 할 수 있습니까

    Kombu와 RabbitMQ를 사용하여 고전적인 게시/구독 디자인 패턴을 구현할 수 있습니까? 나는이 주제를 만드는 제작자를 만든 : 다음 게시자에서 소비하는 소비자를 생성 from kombu import Connection, Exchange, Queue media_exchange = Exchange('media', 'topic', durable=Fal
    rabbitmq amqp kombu 2014-07-23
최근 질문