Можно ли в nginx создать запрос?

пока получилось сделать с помощью curl_easy но это очень плохо

Посмотри в сторону openresty или lua'шных моделей.

если lua - тогда уж лучше использовать tarantool

В какую сторону копать?

В сторону скриптования? Его ж можно скриптовать с помощью Lua/MRuby, если собрать с поддержкой соответствующих модулей.

дернуть локейшен можно через njs легко. но только в процессе обработки какого-то запроса.

зачем второй модуль с listen/notify непонятно. почему просто не дернуть сокет нжинкса внешним процессом?

На сишке? У nginx как раз для этого есть сабреквесты.

Для HTTP-подзапросов есть ngx_http_subrequest(). Скорее всего, у полученного ngx_http_request_t * ты захочешь поменять ->write_event_handler на что-то своё.

njs

не хочу ничего лишнего

зачем второй модуль с listen/notify непонятно. почему просто не дернуть сокет нжинкса внешним процессом?

нету у меня никаких внешних процессов! есть nginx с вебсокетами, который соединён listen/notify с postgres, в котором крутятся очереди (pgq)

На сишке?

как раз - да!

У nginx как раз для этого есть сабреквесты.

знаю, но проблема как раз в том, что реквеста-то нету! и надо его как-то создать!

Для HTTP-подзапросов есть ngx_http_subrequest(). Скорее всего, у полученного ngx_http_request_t * ты захочешь поменять ->write_event_handler на что-то своё.

дак проблема как раз в том, что ngx_http_request_t нету! и надо его как-то создать!

ngx_http_subrequest() инициализирует новый ngx_http_request_t.

ngx_http_subrequest() инициализирует новый ngx_http_request_t.

инициализировать-то - инициализирует, но у этой функции первый аргумент - это старый ngx_http_request_t, а его у меня нет!

не хочу ничего лишнего

BTW это стандатный модуль.

нету у меня никаких внешних процессов! есть nginx с вебсокетами, который соединён listen/notify с postgres, в котором крутятся очереди (pgq)

есть n worker процессов, обрабатывающих входящие запросы, как они у тебя соединены с сокетом на котором ты делаешь listen(от постгреса)?

есть n worker процессов, обрабатывающих входящие запросы, как они у тебя соединены с сокетом на котором ты делаешь listen(от постгреса)?

    location = /ws {
        push_stream_subscriber websocket;
        push_stream_channels_path $arg_id;
    }
    location = /pub {
        push_stream_publisher;
        push_stream_channels_path $arg_id;
    }
    location = /client_unsubscribed {
        internal;
        postgres_pass ngx;
        postgres_query "unlisten $arg_id";
    }
    location = /client_subscribed {
        internal;
        postgres_pass ngx;
        postgres_query "listen $arg_id";
    }

браузер соединяется вебсокетом на ws, первый модуль шлёт подзапрос на client_subscribed, второй модуль шлет listen в постгрес

То есть ты это как бы сам по себе делаешь, без привязки к какому-либо запросу? В таком случае сабреквестами воспользоваться не получится. Используй тогда ngx_add_conn() и ngx_add_event(). Указатель на ngx_connection_t можно получить с помощью ngx_get_connection(). Дальше устанавливаешь колбеки на read и write, и работаешь уже там.

Пример инициализации есть в коде ngx_event_accept().

браузер соединяется вебсокетом на ws...
...шлет listen в постгрес

это не будет работать.

что толку от listen, кто потом будет слушать асинхронные нотификации на этом соединении пг?

соединений pg походу там == числу workerов, кто гарантирует что в одном воркере будут обработаны /ws и /client_subscribed

итд...

это не будет работать.

уже работает! но с помощью curl_easy

что толку от listen, кто потом будет слушать асинхронные нотификации на этом соединении пг?

второй модуль и слушает!

а ngx_http_get_module_ctx как-то может помочь?

Наверное, да. Зависит от того, чего ты пытаешься добиться.

Но если бы у меня была задача наладить коммуникации между двумя модулями, я бы стал задумываться, а в чём на самом деле задача. Если у тебя код в двух модулях решает общую задачу, связан между собой и требует коммуникации, не стоило разбивать его на два модуля. Стоило делать сразу один цельный.

Нет смысла сначала придумывать себе задачу на ровном месте, а потом хаками пытаться её решить.

задача простая: передать асинхронное уведомление из постргресса в вебсокет модули не мои - это готовые, я просто пытаюсь их подружить вместе

где в готовом ngx_postgres поддержка listen/notify ?

в случае >1 workerа задача не простая

где в готовом ngx_postgres поддержка listen/notify

добавить всего пару строк вот докер, в докерфайле - ссылки на исходники, где я и добавил эту поддержку

Тогда всё равно можно решить, но придётся вникнуть в стройную костылеподпорочную систему nginx. У nginx все их структуры публичные, так что даже если они не экспортировали какие-то нужные функции, то никто не мешает заняться творческим копипастингом.

Всегда можно создать сокет самому и сидеть на read/write событиях. Возможно, есть какой-то способ попроще, но найдётся он в процессе реализации.

я почитал твой код, поддержкой это врятли можно назвать, скорее ты похакал этот модуль ).

но. мне непонятно, что ты достичь пытаешься?

ведь если так делать (неважно через nginx или curl), то на КАЖДЫЙ notification будут открываться по два сокета, этож на одних сисколах оверхед эпический...

получилось сделать, но без запроса! (с помощью глобальной переменной и вызова функции первого модуля из второго)