Описание тега anyevent

AnyEvent - это Perl-фреймворк для программирования на основе событий.
1 ответ

Как справиться с AnyEvent, RabbitMQ (heartbeat) и долгосрочными заданиями в Perl?

Я внедряю систему для распределенного выполнения Cronjob (так называемый Cron вычислительный кластер). Cronjobs должны быть поставлены в очередь в очередь сообщений (RabbitMQ), когда наступит время действия. С другой стороны (узлы / работники класте…
18 янв '16 в 10:56
1 ответ

AnyEvent::STOMP::Client + AnyEvent::ForkManger = Временная ошибка

Я пытаюсь написать процесс, который прослушивает ActiveMQ и, основываясь на сообщении, выходит и извлекает данные из веб-сервиса, выполняет некоторую обработку и затем передает данные процесса в другой веб-сервис. (REST/JSON) Приведенный ниже модуль…
05 сен '16 в 21:03
1 ответ

Могу ли я использовать AnyEvent->timer() в AnyEvent::Fork?

Допустим, я работаю с номером N объекта счета. Я хотел бы создать для N Account несколько вилок и самостоятельно включить событие AnyEvent-> timer (). вот как выглядит мой код: for my $num_account (1..2) { my $fork_1 = AnyEvent::Fork ->new ->r…
20 май '14 в 13:37
2 ответа

Понимание асинхронности в Perl на конкретном примере

Я должен написать скрипт, который получает несколько URL-адресов параллельно и выполняет некоторую работу. В прошлом я всегда использовал Parallel::ForkManager для таких вещей, но теперь я хотел узнать что-то новое и попробовать асинхронное программ…
27 апр '16 в 18:56
0 ответов

Параллельная обработка с использованием модуля AnyEvent (Any) с пользовательской функцией

Я пытаюсь использовать модуль AnyEvent для получения некоторой информации о нескольких веб-страницах параллельно. В примере: выборка нескольких веб-страниц параллельно с использованием AnyEvent #!/usr/bin/perl use strict; use warnings; use Data::Dum…
20 мар '18 в 12:00
1 ответ

Использование синтетического дескриптора файла с EV (perl)

У меня есть объект файлового дескриптора, который создан таким образом (слегка отредактирован для ясности): sub TIEHANDLE { return $_[0] if ref($_[0]); my $class = shift; my $self = bless Symbol::gensym(), $class; return $self; } sub new { my ($clas…
03 июн '14 в 08:01
1 ответ

Как сделать асинхронную www-механизацию, используя anyevent

Я провел довольно много исследований по этой теме, и, хотя есть некоторые вопросы, связанные с этим, мне действительно трудно понять, как правильно выполнять асинхронное программирование с использованием AnyEvent и www-mechanize. Я пытаюсь придержив…
30 сен '13 в 01:13
2 ответа

Темы, Коро, Любая путаница

Я относительно новичок в Perl и даже новичок в потоках в Perl. У меня есть Perl-скрипт, который принимает данные из 3 разных источников. (2 запроса LDAP и файл, который не всегда существует) Поскольку некоторые части могут занимать больше времени, ч…
30 июл '12 в 18:45
1 ответ

AnyEvent::RabbitMQ проблемы с закрытыми каналами

Я пишу мастер-программу для публикации сообщений в очереди сообщений ( RabbitMQ). Программа написана на Perl 5 и использует AnyEvent:: RabbitMQ для связи с RabbitMQ. В следующем минимальном примере (для проблемы, с которой я столкнулся) произойдет с…
12 авг '15 в 13:00
1 ответ

Почему в этом примере AnyEvent::Handle не вызывается on_eof?

Это мой простой сервер. Когда я запускаю его и подключаюсь к нему через telnet (порт 5222), и когда telnet завершает соединение, почему не вызывается моя функция on_eof? Т.е. почему не строка "КАТАСТРОФА!!!" печататься? #!/usr/bin/perl use v5.18; us…
23 июн '14 в 19:28
1 ответ

Мониторинг и чтение новых строк в файле?

Программа использует цикл событий AnyEvent. Программа должна читать новые строки, которые иногда (редко) появляются в текстовом файле в локальной файловой системе. Как я понял, AnyEvent::io использовать нельзя. Что я могу посоветовать для чтения нов…
09 сен '18 в 16:14
3 ответа

Запуск AnyEvent под приложением Dancer

Я хотел бы сделать несколько неблокирующих SSH для пары тысяч машин, которые я отслеживаю (мои собственные машины), у меня запущено и запущено приложение Dancer, и я хочу использовать AnyEvent::timer для выполнения SSH команды асинхронны (каждая маш…
20 окт '12 в 22:07
0 ответов

Команды async redis, использующие AnyEvent::Hiredis

Я безуспешно пытаюсь установить переменную окружения, используя AnyEvent::Hiredis, Я использую Redis 4,02 на Centos 7 #!/usr/bin/perl use strict; use AnyEvent::Hiredis; my $redis = AnyEvent::Hiredis->new; $redis->command( ['SET', "ABC", 'foo']…
12 дек '17 в 11:50
2 ответа

Perl Anyevent, не блокирующий Redis Push

У меня есть код ниже, чтобы сделать не блокирующую rpush на сервере redis Когда я запускаю это всего за 1 rpush, код работает нормально, но когда я запускаю это в цикле while, скрипт зависает после первого выполнения. Зачем? #!/usr/bin/perl use AnyE…
30 май '16 в 13:32
1 ответ

AnyEvent работает с Perl 5.26?

Я встретил следующую ошибку: Can't use an undefined value as a subroutine reference at /home/basiliscos/perl5/perlbrew/perls/perl-5.26.0/lib/site_perl/5.26.0/x86_64-linux/AnyEvent/Loop.pm line 248 когда я запускаю свою программу под perl 5.26.0, меж…
10 авг '17 в 19:55
0 ответов

Perl-скрипт с AnyEvent работает недостаточно быстро

Вот небольшой скрипт, который я создал для выполнения HTTP-транзакций из файла со списком URL-адресов. Проблема в том, что он не может выполнять HTTP-транзакции так быстро, как мне бы хотелось. Точнее, я установил скорость в 200 / секунд, но она мог…
20 апр '17 в 18:43
2 ответа

Переподключитесь, используя AnyEvent::Handle и tcp_connect

У меня есть простой TCP-сервер и клиент, написанный с использованием AnyEvent::Handle левереджа tcp_connect а также tcp_server, Клиент подключается к серверу и отправляет строку Test Message каждые 5 секунд. Это работает без проблем, если сервер дос…
21 июн '15 в 18:14
0 ответов

XML::LibXML обрабатывает символы, закодированные в gbk

Следующий скрипт на Perl работает. Однако если содержимое HTML содержит символы, основанные на gbk, они не смогут извлечь URL-адреса. Например, этот сайт " http://list.jd.com/6196-6198-6209-0-0-0-0-0-0-0-1-3-1-1-1-72-4137-0.html"имеет несколько симв…
08 май '14 в 15:15
1 ответ

Как лучше всего в Perl установить таймер, чтобы остановить длительный процесс?

У меня есть приложение, которое вызывает потенциально длительный процесс. Я хочу, чтобы моя программа, вызывающая этот процесс, отменила ее в любой заданный момент и перешла к следующей записи, когда превышено ограничение по времени. Используя Perl-…
19 ноя '17 в 22:04
1 ответ

Как настроить AnyEvent::DNS resolver по умолчанию?

Как настроить AnyEvent::DNS по умолчанию, я хочу изменить max_outstanding, reuse, timeout, Есть переменная окружения $ENV{PERL_ANYEVENT_MAX_OUTSTANDING_DNS}а как поменять reuse а также timeout?
17 апр '17 в 19:38