이것은 매우 흥미 롭습니다! 무슨 일이야? 마스터 과정은 마스터 포크에게 (또한 노동자라는) 새로운 프로세스는 근로자가 온라인 상태 일 때 알고 오도록 마스터는 또한, 자체에 리스너를 활성화를 시작한다. (근로자가 온라인 상태가되면 주인은 인사 메시지를 보냅니다.) 근로자가 시작되었습니다. 근로자는 청취자를 등록합니다. 따라서 메시지가 주인에 의해 작업자에
이 클러스터 및 작업자 (child_process)로 현재 실험 중입니다. ... 메신저 내 클래스에 "process.on"기능을 결합하려고하지만, 작동 밤은 var coresCount = require('os').cpus().length;
var exec = require('child_process').exec;
var cluster = require
저는 django-celery 3.2와 celery 3.1.25를 사용하고 있습니다. 나는 설정 아래에 추가 한 - ImportError: No module named vine.five 단계 3.2 재현 아래 오류 CELERY_TASK_ACKS_LATE = True
task_reject_on_worker_lost = True
응용 프로그램의 결과를 내
내 범위는 cron 작업을 통해 클라우드에서 파이썬 스크립트 (웹 사이트의 텍스트를 스크랩하고 csv 파일로 저장)를 실행하는 것입니다. 이것을 위해 나는 Heroku를 선택했다. 작업자를 배치하려고 시도 할 때 푸시 거부가 발생하기 때문에 막혔습니다. 다음은 내가하는 일입니다. 내 scrapit.py와 Procfile ('worker : node scra
나는 창에 독립 클러스터 관리자를 사용하여 스파크 응용 프로그램을 배포하려면 노력하고 있어요 마스터 측에서 너무 스파크 아파치에 마스터에 연결하지 못했습니다 \bin>spark-class org.apache.spark.deploy.master.Master 와 슬레이브 측의 (IP :. 192 0.75)은 내가 실행 : \bin>spark-class org.
독립형 클러스터 관리자를 사용하여 Spark Apache 응용 프로그램을 배포하고 있습니다. 나는이 실행되는 : 내 아키텍처는 2 윈도우 머신 마스터로 한 세트 및 슬레이브로 또 다른 세트 (근로자) 마스터 사용 \bin>spark-class org.apache.spark.deploy.master.Master을하고이 웹 UI를 보여줍니다 것입니다 : 노예를
다른 클래스에서 제공하는 일부 메소드를 사용하는 직렬 포트에서 작동하는 Backgroundworker를 만들었습니다. 이러한 메서드에서 예외가 발생할 때마다 작업자를 취소하고 싶습니다. 사실, 나는 이벤트를 사용하여 그것을 어떻게하는지 약간의 아이디어가 있지만, 최적의 해결책이나 좋은 습관이 아닌 것 같아 걱정됩니다. 그럴 경우 각 방법마다 이벤트를 발생시
셀프 작업자가 동일한 작업을 여러 번 병렬로 실행하는 데 문제가 있습니다. 나는 3 명의 작업자를두고 모든 작업자에 대해 --concurrency를 2로 설정했습니다. 하지만 3 명의 작업자 모두에게 3 개의 작업 만 실행합니다. 저는 약 10 명의 근로자를 추궁하고 싶습니다. celery -A my_app worker -l info -c 2 -n work
node.js의 함수에 무거운 알고리즘이 있습니다. 성능을 절약하기 위해이 함수를 다른 스레드에서 호출하려고합니다. 시도 : let ChildProcess = require('child_process');
const thread1 = ChildProcess.spawn(function()
{
reloadData();
});
function
내가 뷰의 웹팩 템플릿 (https://github.com/vuejs-templates/webpack을)와 PapaParse의 노동자 옵션 (http://papaparse.com/#worker)를 활용하는 시도를하고 있어요하지만 문제가 있어요 파일을 번들 파일과 별도로 작성해야하므로 https://github.com/danderson00/webpack-wo