YZ
вопрос не ясен
Size: a a a
2020 March 02
И
S S
Привет всем, как обычно делают ссылки которые приходят на почту с текстом при регистрации "перейдите по ссылке чтобы подтвердить ваш аккаунт"?
Чекаешь по query параметру какой-нибудь ключ и ставишь флаг что юзер почту подтвердил
SS
Чекаешь по query параметру какой-нибудь ключ и ставишь флаг что юзер почту подтвердил
Типа при регистрации создавать в таблице verified_id?
IS
привет всем подскажыте как я могу реализовать логику передачи данных для воркеров с мастера. у меня есть стрим который читает файл и разбивает на количество воркеров и теперь я хочу передать каждому воркеру его кусок данных. есть идеи я запутался совсем
И
S S
Типа при регистрации создавать в таблице verified_id?
либо отдельную таблицу с user_id + verification_code
И
привет всем подскажыте как я могу реализовать логику передачи данных для воркеров с мастера. у меня есть стрим который читает файл и разбивает на количество воркеров и теперь я хочу передать каждому воркеру его кусок данных. есть идеи я запутался совсем
собираешь пачку данных и через шину отдаёшь
SS
либо отдельную таблицу с user_id + verification_code
Благодарю!
IS
я запускаю фор и создаю кучу воркеров, читаю файл и должен по кускам его отправлять
Z
Сап, товарищи. Какие есть модули для работы с файлами docx? У меня есть шаблон документа ворд, нужно вставлять в него некоторые данные
u
Сап, товарищи. Какие есть модули для работы с файлами docx? У меня есть шаблон документа ворд, нужно вставлять в него некоторые данные
IS
есть такой код который должен запускать чтение файла и отправлять сообщение воркерам но он не работет как пофиксть?
IS
if (cluster.isMaster) {
for(let i = 0; i < cpuCount; i++) {
//cluster.schedulingPolicy = cluster.SCHED_NONE;
cluster.fork();
}
function chunkArrayDrob(myArray, chunk_size){
let results = [];
while (myArray.length) {
results.push(myArray.splice(0, chunk_size));
}
return results;
}
let readLinesCount;
let lastPieceOfData = '';
read.on('data', (chunk) => {
const chunkArray = (lastPieceOfData + chunk).split('\n');
lastPieceOfData = chunkArray[chunkArray.length - 1];
const workerData = chunkArray.slice(0, -1);
readLinesCount = readLinesCount + chunkArray.length - 1;
//worker.send(workerData.length);
const step = Math.ceil(parseInt(workerData.length) / cpuCount);
let result = chunkArrayDrob(workerData, step);
for(let i = 0; i < cpuCount; i++) {
const worker = cluster.fork();
worker.send(result[i+1]);
}
});
for(let i = 0; i < cpuCount; i++) {
//cluster.schedulingPolicy = cluster.SCHED_NONE;
cluster.fork();
}
function chunkArrayDrob(myArray, chunk_size){
let results = [];
while (myArray.length) {
results.push(myArray.splice(0, chunk_size));
}
return results;
}
let readLinesCount;
let lastPieceOfData = '';
read.on('data', (chunk) => {
const chunkArray = (lastPieceOfData + chunk).split('\n');
lastPieceOfData = chunkArray[chunkArray.length - 1];
const workerData = chunkArray.slice(0, -1);
readLinesCount = readLinesCount + chunkArray.length - 1;
//worker.send(workerData.length);
const step = Math.ceil(parseInt(workerData.length) / cpuCount);
let result = chunkArrayDrob(workerData, step);
for(let i = 0; i < cpuCount; i++) {
const worker = cluster.fork();
worker.send(result[i+1]);
}
});
IS
насколько я понимаю я не могу вызывать форк несколько раз?
KL
if (cluster.isMaster) {
for(let i = 0; i < cpuCount; i++) {
//cluster.schedulingPolicy = cluster.SCHED_NONE;
cluster.fork();
}
function chunkArrayDrob(myArray, chunk_size){
let results = [];
while (myArray.length) {
results.push(myArray.splice(0, chunk_size));
}
return results;
}
let readLinesCount;
let lastPieceOfData = '';
read.on('data', (chunk) => {
const chunkArray = (lastPieceOfData + chunk).split('\n');
lastPieceOfData = chunkArray[chunkArray.length - 1];
const workerData = chunkArray.slice(0, -1);
readLinesCount = readLinesCount + chunkArray.length - 1;
//worker.send(workerData.length);
const step = Math.ceil(parseInt(workerData.length) / cpuCount);
let result = chunkArrayDrob(workerData, step);
for(let i = 0; i < cpuCount; i++) {
const worker = cluster.fork();
worker.send(result[i+1]);
}
});
for(let i = 0; i < cpuCount; i++) {
//cluster.schedulingPolicy = cluster.SCHED_NONE;
cluster.fork();
}
function chunkArrayDrob(myArray, chunk_size){
let results = [];
while (myArray.length) {
results.push(myArray.splice(0, chunk_size));
}
return results;
}
let readLinesCount;
let lastPieceOfData = '';
read.on('data', (chunk) => {
const chunkArray = (lastPieceOfData + chunk).split('\n');
lastPieceOfData = chunkArray[chunkArray.length - 1];
const workerData = chunkArray.slice(0, -1);
readLinesCount = readLinesCount + chunkArray.length - 1;
//worker.send(workerData.length);
const step = Math.ceil(parseInt(workerData.length) / cpuCount);
let result = chunkArrayDrob(workerData, step);
for(let i = 0; i < cpuCount; i++) {
const worker = cluster.fork();
worker.send(result[i+1]);
}
});
код воркера покажи
IS
else if (cluster.isWorker) {
process.on('message', (msg) => {
process.send(msg);
console.log(cluster.worker.id, msg)
});
}
process.on('message', (msg) => {
process.send(msg);
console.log(cluster.worker.id, msg)
});
}
IS
код воркера покажи
100% в мастере дело
IS
я хочу для каждого воркера отправлять свой кусок данных
IS
есть кто?