Size: a a a

2021 June 24

W

Warstone in Modern::Perl
Просто если к одному шарду будет больше одного подключения, то вы не сможете нормально размазать нагрузку. Будут затыки.
источник

М

Млюшевый Пишка... in Modern::Perl
get_filtered_blocks - это поход в шарды
источник

М

Млюшевый Пишка... in Modern::Perl
за блоками
источник

W

Warstone in Modern::Perl
Или в агрегатор.
источник

М

Млюшевый Пишка... in Modern::Perl
не понял тут
источник

W

Warstone in Modern::Perl
Ну я раздробил агрегатор на маленький агрегатор и процессор результатов.
источник

М

Млюшевый Пишка... in Modern::Perl
я вижу осколки от дробления 8))
источник

W

Warstone in Modern::Perl
Склеивать это все будет весело, да...
источник

М

Млюшевый Пишка... in Modern::Perl
особенно когда на него ходит 450к раз в минуту..
источник

W

Warstone in Modern::Perl
Да не... Это не нагрузка, на самом деле... Весь вопрос бизнес логики. 450К в минуту выдержит одна тачка и не напряжется сильно.
источник

W

Warstone in Modern::Perl
Даже если это один процесс.
источник

М

Млюшевый Пишка... in Modern::Perl
sub get_by_ctx2 { вот так у нас называется фукция, которая получает список блоков, при 1500 блоков она работает 15мс, а при 3000 40
источник

М

Млюшевый Пишка... in Modern::Perl
вот её я и буду пилить.
источник

М

Млюшевый Пишка... in Modern::Perl
да и вообще. случшай, число 10 оно условное, надо поиграться будет с количесвом, может 5 хватит
источник

W

Warstone in Modern::Perl
Ну... В ней:
$ua = LWP::UserAgent->new(..)
$ua->get("agg_host:port/?filter_params");
return $ua->content;
источник

VG

Vadim Goncharov in Modern::Perl
а можно просто описать методы FREEZE и THAW
источник

М

Млюшевый Пишка... in Modern::Perl
нет
источник

W

Warstone in Modern::Perl
А почему нет-то?
источник

М

Млюшевый Пишка... in Modern::Perl
в ней
use UniEvent;

my $tcp = UniEvent::Tcp->new;

$tcp->connect($host, $port, sub {
   my ($tcp, $error) = @_;
   die("cannot connect: $error\n") if $error;
   ...
});

$tcp->write($data, sub {
   my ($tcp, $error) = @_;
   die("writing data error: $error\n") if $error;
   ...
});

$tcp->read_callback(sub {
   my ($tcp, $data, $error) = @_;
   die("reading data error: $error\n") if $error;
   ...
});

$tcp->eof_callback(sub {
   my $tcp = shift;
   ...
});

$tcp->loop->run;
источник

М

Млюшевый Пишка... in Modern::Perl
на все шарды
источник