 | 몽고 루스몽고를 백엔드 저장소로 사용하는 대기열 |
| 지금 다운로드 | |
몽고 루스 순위 및 요약
광고
몽고 루스 태그
몽고 루스 설명
MongoQueue는 백엔드 저장소로서 Mongo를 사용하는 대기열입니다 .Usagea 대기열은 몽고 컬렉션과 소비자 식별자로 인스턴스화 할 수 있습니다. 소비자 식별자는 대기열에서 작업을 수행하는 여러 대기열 소비자를 구별하는 데 도움이됩니다. >> Pymongo 가져 오기 연결에서 >> 몽고 루스 가져 오기 몽고 루스 >> Queue = Mongoqueue (... 연결 (test_db) .doctest_queue, ... consumer_id = "consumer-1", ... timeout = 300, ... max_atempts = 3)``mongoqueue`` 클래스``시간 초과``매개 변수는 소비자가 실패한 것으로 간주되기 전에 소비자가 직업을 보유 할 수있는 시간을 초과하며,``max_atempts보다``max_attempt ``매개 변수는 영구적으로 실패하고 더 이상 처리되지 않습니다. 사전을 전달하여 대기열에 배치 할 수 있습니다. >> Queue.put ({ "foobar": 1}) 작업``우선 순위 ''키와 정수 값은 우선 순위가 낮은 항목보다 먼저 작업을 처리하게하는 사전에 지정 될 수 있습니다. >> Queue.put ({ "foobar": 0, "우선 순위": 1}) 대기열에서``다음 '메소드를 호출하여 항목을 가져올 수 있습니다. 이것은 작업 개체를 반환합니다. >> Job = queue.next () >> Job.Data { "Foobar": 1} 작업 클래스는 작업에 대한 일부 제어 메소드를 노출, 진행 상황, 완료, 오류 또는 작업을 큐로 다시 릴리스하기 위해 작업에 대한 일부 제어 방법을 노출합니다. -``완료 '는 작업을 완료하고 대기열에서 제거합니다. -``오류 '는 메시지로 선택적으로 지정되거나, 작업을 큐로 다시 릴리스하고 시도를 증가시키고 작업에 오류 메시지를 저장합니다. -``진행률 '은 선택적으로 진행률 수 정수를 취하고, 작업에 대한 진행 상황을 취하고 잠금 시간 초과를 재설정합니다. -``릴리스` '은 수영장으로 다시 일자리를 놓습니다. 시도 카운터는 modified되지 않습니다. 수준은 컨텍스트 관리자 프로토콜을 지원합니다. >> 데이터로 작업 : ... 인쇄 데이터 { "foobar : 0} 작업없이 컨텍스트 클로저가 종료되면 예외가있는 경우 오류가 Job.Product의 홈페이지에 저장됩니다.
몽고 루스 관련 소프트웨어
