r
вот так я делаю
Size: a a a
2020 November 30
JD
вот так я делаю
поэтому у тебя проблемы )
r
поэтому у тебя проблемы )
а нормально как ?
JD
а нормально как ?
я делаю так
загружаешь список тех кому надо рассылать в память/редис
загружаешь список тех кому надо рассылать в память/редис
setInterval(()=>{
...
sendHoroscope(...);
},250)r
я делаю так
загружаешь список тех кому надо рассылать в память/редис
загружаешь список тех кому надо рассылать в память/редис
setInterval(()=>{
...
sendHoroscope(...);
},250)список у меня в монге, можно конечно его и сразу получить в переменную, а не перебирать monngoose, я делал так раньше, в этом чате мне написали что это говно, и надо делать так, как у меня сейчас, но по сути в обоих вариантах задержка во запроса во время рассылки присутствует
f
Интересно-интересно про монгу и постгре
JD
список у меня в монге, можно конечно его и сразу получить в переменную, а не перебирать monngoose, я делал так раньше, в этом чате мне написали что это говно, и надо делать так, как у меня сейчас, но по сути в обоих вариантах задержка во запроса во время рассылки присутствует
ну ты попробовал как написали, если работает - хорошо, если нет - попробуй по-другому )
i
А монга же поддерживает несколько запросов одновременно?
r
ну ты попробовал как написали, если работает - хорошо, если нет - попробуй по-другому )
в нодном чате мне сказали типа решай через процесс и запускай его кроном, они будут запаралелены и будет тебе счастье, вот пришёл сюда узнать, делал ли кто нибудь так
JD
в нодном чате мне сказали типа решай через процесс и запускай его кроном, они будут запаралелены и будет тебе счастье, вот пришёл сюда узнать, делал ли кто нибудь так
ясно ) решений естественно может быть несколько. видимо те кто советуют отдельный процесс не умеют делать в одном процессе )
но если и делать в отдельном, то просто отправлять http запросом.
но если и делать в отдельном, то просто отправлять http запросом.
r
ясно ) решений естественно может быть несколько. видимо те кто советуют отдельный процесс не умеют делать в одном процессе )
но если и делать в отдельном, то просто отправлять http запросом.
но если и делать в отдельном, то просто отправлять http запросом.
попробую, спс за участие!
r
А монга же поддерживает несколько запросов одновременно?
монге вообще пофиг, нода не отдаст ответ из монги, пока не закончит свои грязные дела по рассылке, если без тайм аута, с тайм аутом отдаёт ессено
i
монге вообще пофиг, нода не отдаст ответ из монги, пока не закончит свои грязные дела по рассылке, если без тайм аута, с тайм аутом отдаёт ессено
Мб потому что с асинком траблы?
i
Если сама рассылка асинхронная в том же нод кроне, не вижу, как это будет основному процессу мешать
OS
если сделаешь aysnc оно тоже мешать не будет
Будет
r
Если сама рассылка асинхронная в том же нод кроне, не вижу, как это будет основному процессу мешать
вот аинхронная рассылка
const delay = ms => new Promise(resolve => setTimeout(resolve, ms))
await User.find({ sent: true }).cursor()
.eachAsync(async function (user) {
await sendHoroscope(bot, user);
await delay(250);
})
const delay = ms => new Promise(resolve => setTimeout(resolve, ms))
await User.find({ sent: true }).cursor()
.eachAsync(async function (user) {
await sendHoroscope(bot, user);
await delay(250);
})
r
Будет
прива, да, юзаю сейчас твой код
r
только хочу его в отдельном модуле теперь по крону
i
А можешь показать с каким кодом отдает, а с каким нет?
r
А можешь показать с каким кодом отдает, а с каким нет?
вот с этим отдаёт, а если delay в 0 поставить, будет пауза пока не кончится рассылка