{"id":454346,"date":"2025-04-01T21:01:34","date_gmt":"2025-04-01T21:01:34","guid":{"rendered":"http:\/\/savepearlharbor.com\/?p=454346"},"modified":"-0001-11-30T00:00:00","modified_gmt":"-0001-11-29T21:00:00","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=454346","title":{"rendered":"\u0411\u0430\u043b\u0430\u043d\u0441\u0438\u0440\u043e\u0432\u043a\u0430 \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438 LLM \u0447\u0435\u0440\u0435\u0437 Nginx<\/span>"},"content":{"rendered":"
<\/div>\n
\n
\n
\n
\n
\n

\u0418\u0441\u0445\u043e\u0434\u043d\u044b\u0439 \u043a\u043e\u0434, \u0440\u0430\u0437\u043e\u0431\u0440\u0430\u043d\u043d\u044b\u0439 \u0432 \u0441\u0442\u0430\u0442\u044c\u0435, \u043e\u043f\u0443\u0431\u043b\u0438\u043a\u043e\u0432\u0430\u043d \u0432 \u044d\u0442\u043e\u043c \u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u0438<\/a><\/p>\n<\/blockquote>\n

\u0412 \u0438\u043d\u0442\u0435\u0440\u043d\u0435\u0442\u0435 \u0441\u0443\u0449\u0435\u0441\u0442\u0432\u0443\u0435\u0442 \u043c\u043d\u043e\u0436\u0435\u0441\u0442\u0432\u043e \u043f\u0440\u0438\u043c\u0435\u0440\u043e\u0432, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u044e\u0442 \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0438\u0442\u044c ChatGPT 3.5 \u0431\u0435\u0437 \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442\u043e\u0432 \u043a \u0442\u0435\u043b\u0435\u0433\u0440\u0430\u043c \u0431\u043e\u0442\u0443. \u041e\u0434\u043d\u0430\u043a\u043e, \u043a\u043e\u0433\u0434\u0430 \u0440\u0435\u0447\u044c \u0437\u0430\u0445\u043e\u0434\u0438\u0442 \u043e \u0431\u043e\u043b\u044c\u0448\u043e\u043c \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u0435 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u0435\u0439, \u043d\u0435 \u0441\u0443\u0449\u0435\u0441\u0442\u0432\u0443\u044e\u0442 \u043f\u0440\u0438\u043c\u0435\u0440\u043e\u0432 \u0440\u0430\u0441\u043f\u0440\u0435\u0434\u0435\u043b\u0435\u043d\u0438\u044f \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438 \u043f\u043e \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u0438\u043c \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u0430\u043c: \u0432\u0441\u0435 \u0442\u0443\u0442\u043e\u0440\u0438\u0430\u043b\u044b \u0432 \u0438\u043d\u0442\u0435\u0440\u043d\u0435\u0442\u0435 \u0437\u0430\u043f\u0443\u0441\u043a\u0430\u044e\u0442 \u043c\u043e\u043d\u043e\u043b\u0438\u0442 \u0441 \u043e\u0434\u043d\u043e\u0439 \u0440\u0435\u043f\u043b\u0438\u043a\u043e\u0439<\/p>\n

\"https:\/\/github.com\/telegraf\/telegraf\/issues\/423\"<\/p>\n
https:\/\/github.com\/telegraf\/telegraf\/issues\/423<\/a><\/figcaption><\/div>\n<\/figure>\n

\u0422\u0430\u043a \u0436\u0435, \u043d\u0430 \u043f\u0440\u0430\u043a\u0442\u0438\u043a\u0435 \u0440\u0430\u0431\u043e\u0442\u044b \u0441 NodeJS, \u044f \u0441\u0442\u0430\u043b\u043a\u0438\u0432\u0430\u043b\u0441\u044f \u0441 \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u043e\u0439, \u043a\u043e\u0433\u0434\u0430 \u043c\u043d\u043e\u0433\u043e Promise \u0432 \u0441\u0442\u0430\u0442\u0443\u0441\u0435 pending<\/a> \u0437\u0430\u043c\u0435\u0434\u043b\u044f\u044e\u0442 \u0440\u0430\u0431\u043e\u0442\u0443 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u043e\u0439 \u043d\u0430 \u0441\u0431\u043e\u0440\u0449\u0438\u043a \u043c\u0443\u0441\u043e\u0440\u0430. \u0414\u043e\u0431\u0430\u0432\u0438\u0432 \u0441\u0442\u043e\u0440\u043e\u043d\u043d\u0438\u0435 \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442\u044b<\/a> (\u0434\u0430\u0432 ChatGPT \u0432\u044b\u0437\u044b\u0432\u0430\u0442\u044c \u0432\u043d\u0435\u0448\u043d\u0438\u0438 \u0444\u0443\u043d\u043a\u0446\u0438\u0438 \u0441 \u0437\u0430\u043f\u0440\u043e\u0441\u0430\u043c\u0438 \u043a \u0431\u0430\u0437\u0435 \u0434\u0430\u043d\u043d\u044b\u0445) \u043f\u043e\u0442\u0440\u0435\u0431\u0443\u0435\u0442\u0441\u044f \u0434\u0443\u043c\u0430\u0442\u044c \u043a\u0430\u043a \u043c\u0438\u043d\u0438\u043c\u0443\u043c \u043e \u0441\u043e\u0437\u0434\u0430\u043d\u0438\u0438 \u0440\u0435\u043f\u043b\u0438\u043a \u043c\u043e\u043d\u043e\u043b\u0438\u0442\u0430, \u0447\u0442\u043e\u0431\u044b \u0440\u0430\u0437\u0434\u0443\u0432\u0430\u043d\u0438\u044f \u043e\u0447\u0435\u0440\u0435\u0434\u0438 \u043e\u0436\u0438\u0434\u0430\u043d\u0438\u044f \u0434\u0430\u043d\u043d\u044b\u0445 \u0438\u0437 \u0431\u0430\u0437\u044b<\/p>\n

\u0410\u0440\u0445\u0438\u0442\u0435\u043a\u0442\u0443\u0440\u0430 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f<\/h2>\n

\u0414\u043b\u044f \u0431\u0430\u043b\u0430\u043d\u0441\u0438\u0440\u043e\u0432\u043a\u0438 \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438 \u0441\u0430\u043c\u044b\u043c \u043e\u0447\u0435\u0432\u0438\u0434\u043d\u044b\u043c \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442\u043e\u043c \u044f\u0432\u043b\u044f\u0435\u0442\u0441\u044f Nginx upstream<\/a> — \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442 \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u0442 WebSocket \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435 \u043d\u043e\u0432\u043e\u0433\u043e \u043a\u043b\u0438\u0435\u043d\u0442\u0430 \u043d\u0430 \u043f\u043e\u0440\u0442 80 \u0438 \u0432 \u043f\u043e\u0440\u044f\u0434\u043a\u0435 \u043e\u0447\u0435\u0440\u0435\u0434\u0438 \u043f\u0440\u043e\u043a\u0441\u0438\u0440\u0443\u0435\u0442 \u0435\u0433\u043e \u043d\u0430 8081, 8082, …, 8085 \u0437\u0430\u0432\u0438\u0441\u0438\u043c\u043e \u043e\u0442 \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u0430 \u0440\u0435\u043f\u043b\u0438\u043a. \u0415\u0441\u043b\u0438 \u043a\u043b\u0438\u0435\u043d\u0442 \u043d\u0435 \u043f\u0440\u043e\u044f\u0432\u043b\u044f\u0435\u0442 \u0430\u043a\u0442\u0438\u0432\u043d\u043e\u0441\u0442\u044c 15 \u043c\u0438\u043d\u0443\u0442, \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435 \u043f\u0440\u0438\u0440\u044b\u0432\u0430\u0435\u0442\u0441\u044f, \u0435\u0441\u043b\u0438 \u0431\u0443\u0434\u0435\u0442 \u043d\u043e\u0432\u043e\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435, \u043e\u043d\u043e \u0441\u043e\u0437\u0434\u0430\u0441\u0442\u0441\u044f \u0437\u0430\u043d\u043e\u0433\u043e.<\/p>\n

\"https:\/\/nginx.org\/en\/docs\/http\/ngx_http_upstream_module.html\"<\/p>\n
https:\/\/nginx.org\/en\/docs\/http\/ngx_http_upstream_module.html<\/a><\/figcaption><\/div>\n<\/figure>\n

\u0420\u0435\u043f\u043b\u0438\u043a\u0438 \u0441\u043e\u0445\u0440\u0430\u043d\u044f\u044e\u0442 \u0438\u0441\u0442\u043e\u0440\u0438\u044e \u043f\u0435\u0440\u0435\u043f\u0438\u0441\u043a\u0438 \u0432 Redis, \u0447\u0442\u043e \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0435\u0442 \u0432\u043e\u0441\u0441\u043e\u0437\u0434\u0430\u0442\u044c \u043a\u043e\u043d\u0442\u0435\u043a\u0441\u0442 \u043d\u0435 \u0441\u043c\u043e\u0442\u0440\u044f \u043d\u0430 \u0442\u043e, \u0447\u0442\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0435\u0442 \u043d\u043e\u0432\u044b\u0439 \u043f\u0440\u043e\u0446\u0435\u0441\u0441. \u0421\u043e\u0437\u0434\u0430\u0432\u0430\u0442\u044c \u0440\u0435\u043f\u043b\u0438\u043a\u0438 \u0431\u0443\u0434\u0435\u0442 PM2 <\/a>— \u043d\u0430\u0438\u0431\u043e\u043b\u0435\u0435 \u043d\u0430\u0442\u0438\u0432\u043d\u044b\u0439 \u0441\u043f\u043e\u0441\u043e\u0431 \u0434\u043b\u044f \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0439 \u0441\u0442\u0435\u043a\u0430 NodeJS<\/p>\n

\"https:\/\/pm2.io\/docs\/plus\/overview\/\"<\/p>\n
https:\/\/pm2.io\/docs\/plus\/overview\/<\/a><\/figcaption><\/div>\n<\/figure>\n

\u0422\u0430\u043a \u0436\u0435, \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044f PM2, \u0437\u0430 40$ \u0432 \u043c\u0435\u0441\u044f\u0446 \u043c\u043e\u0436\u043d\u043e \u043a\u0443\u043f\u0438\u0442\u044c \u0433\u043e\u0442\u043e\u0432\u043e\u0435 \u0443\u0432\u0435\u0434\u043e\u043c\u043b\u0435\u043d\u0438\u0435 \u043e \u0438\u043d\u0446\u0438\u0434\u0435\u043d\u0442\u0430\u0445 \u043f\u043e Slack \/ Email, \u043c\u043e\u043d\u0438\u0442\u043e\u0440\u0438\u043d\u0433 \u0441\u0435\u0440\u0432\u0435\u0440\u0430 \u043f\u043e \u0441\u0442\u0430\u043d\u0434\u0430\u0440\u0442\u043d\u044b\u043c \u043c\u0435\u0442\u0440\u0438\u043a\u0430\u043c \u0442\u0430\u043a\u0438\u043c \u043a\u0430\u043a CPUs: cores, hardware threads, virtual threads, Memory: capacity, Network interfaces, Storage devices: I\/O, capacity, \u0432\u0440\u0435\u043c\u044f \u043e\u0442\u043a\u043b\u0438\u043a\u0430 \u0438 \u0442\u0434. \u042d\u0442\u043e \u044d\u043a\u043e\u043d\u043e\u043c\u0438\u0442 \u0434\u0435\u043d\u044c\u0433\u0438 \u043d\u0430 Dev Ops \u0434\u043e \u0441\u0430\u043c\u043e\u043e\u043a\u0443\u043f\u0430\u0435\u043c\u043e\u0441\u0442\u0438 \u043f\u0440\u043e\u0435\u043a\u0442\u0430.<\/p>\n

\u0424\u0430\u0439\u043b\u044b \u043a\u043e\u043d\u0444\u0438\u0433\u0443\u0440\u0430\u0446\u0438\u0438<\/h2>\n

\u0427\u0442\u043e\u0431\u044b \u043d\u0435 \u0441\u043f\u0435\u0446\u0438\u0430\u043b\u0438\u0437\u0438\u0440\u043e\u0432\u0430\u0442\u044c Linux \u043d\u0430 \u043c\u0430\u0448\u0438\u043d\u0435 \u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a\u0430 \u043f\u043e\u0434 \u043e\u0434\u0438\u043d \u043f\u0440\u043e\u0435\u043a\u0442, \u043e\u0431\u0435\u0440\u043d\u0435\u043c Nginx \u0432 Docker. \u0414\u043b\u044f \u044d\u0442\u043e\u0433\u043e, \u043d\u0430\u043f\u0438\u0448\u0435\u043c docker-compose.yaml<\/code><\/p>\n

version: '3.8'  services:   nginx:     image: nginx:1.27.4     ports:       - \"80:80\"     extra_hosts:       - \"host.docker.internal:host-gateway\"     volumes:       - .\/config\/nginx.conf:\/etc\/nginx\/nginx.conf:ro       - .\/logs\/nginx:\/var\/log\/nginx <\/code><\/pre>\n
\u0418 \u0441\u043e\u0437\u0434\u0430\u0434\u0438\u043c \u0441\u043e\u043f\u0443\u0442\u0441\u0442\u0432\u0443\u044e\u0449\u0438\u0439 .\/config\/nginx.config<\/code> \u0441 \u043f\u0435\u0440\u0435\u0447\u0438\u0441\u043b\u0435\u043d\u0438\u0435\u043c \u0440\u0435\u043f\u043b\u0438\u043a<\/p>\n
user nginx; worker_processes auto;  error_log \/var\/log\/nginx\/error.log warn; pid \/var\/run\/nginx.pid;  events {     worker_connections 1024;     use epoll;     multi_accept on; }  http {     include \/etc\/nginx\/mime.types;     default_type application\/octet-stream;      log_format main '$remote_addr - $remote_user [$time_local] \"$request\" '                     '$status $body_bytes_sent \"$http_referer\" '                     '\"$http_user_agent\" \"$http_x_forwarded_for\"';      access_log \/var\/log\/nginx\/access.log main;      upstream local_websocket_servers {         server host.docker.internal:8081;  # Using host.docker.internal from hosts shared from host machine         server host.docker.internal:8082;         server host.docker.internal:8083;         server host.docker.internal:8084;         server host.docker.internal:8085;         least_conn;     }      map $http_upgrade $connection_upgrade {         default upgrade;         ''      close;     }      server {         listen 80;         server_name localhost;          location \/ {             proxy_pass http:\/\/local_websocket_servers$is_args$args;                          # WebSocket-specific headers             proxy_http_version 1.1;             proxy_set_header Upgrade $http_upgrade;             proxy_set_header Connection $connection_upgrade;                          # Preserve original headers and connection details             proxy_set_header Host $host;             proxy_set_header X-Real-IP $remote_addr;             proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;             proxy_set_header X-Forwarded-Proto $scheme;              # Close upstream if client disconnects             proxy_ignore_client_abort on;                          # Long-lived connection settings             proxy_read_timeout 86400s;             proxy_send_timeout 86400s;                          # Buffer and performance settings             proxy_buffer_size 128k;             proxy_buffers 4 256k;             proxy_busy_buffers_size 256k;         }     } } <\/code><\/pre>\n
\u0414\u043b\u044f \u0437\u0430\u043f\u0443\u0441\u043a\u0430 \u0440\u0435\u043f\u043b\u0438\u043a \u0447\u0435\u0440\u0435\u0437 pm2 \u0441\u043e\u0437\u0434\u0430\u0434\u0438\u043c pm2.config.cjs<\/code>. \u041f\u043e \u0441\u0441\u044b\u043b\u043a\u0435 \u043b\u0435\u0436\u0438\u0442 package.json<\/a> \u0441 \u0441\u043a\u0440\u0438\u043f\u0442\u0430\u043c\u0438 \u0434\u043b\u044f \u0437\u0430\u043f\u0443\u0441\u043a\u0430 \u043f\u0440\u043e\u0435\u043a\u0442\u0430 \u0447\u0435\u0440\u0435\u0437 npm start<\/code><\/p>\n
const path = require(\"path\"); const os = require(\"os\"); const dotenv = require('dotenv');  const readConfig = () => dotenv.parse(\".\/.env\");  const getPath = (unixPath) => {   return path.resolve(unixPath.replace('~', os.homedir())); };  const createBun = (index) => ({   name: `bun-ws-${index}`,   script: \".\/src\/server.ts\",   interpreter: getPath(\"~\/.bun\/bin\/bun\"),   args: [\"--server\", `--port=808${index}`],   out_file: `.\/logs\/pm2\/bun-ws-${index}-out.log`,   error_file: `.\/logs\/pm2\/bun-ws-${index}-error.log`,   log_date_format: \"YYYY-MM-DD HH:mm:ss\",   merge_logs: true,   env: readConfig(), });  module.exports = {   apps: [     \/*     {       name: \"bun-ws-1\",       script: \".\/src\/server.ts\",       interpreter: getPath(\"~\/.bun\/bin\/bun\"),       args: [\"--server\", \"--port=8081\"],       out_file: \".\/logs\/pm2\/bun-ws-1-out.log\",       error_file: \".\/logs\/pm2\/bun-ws-1-error.log\",       log_date_format: \"YYYY-MM-DD HH:mm:ss\",       merge_logs: true,     },     *\/     createBun(1),     createBun(2),     createBun(3),     createBun(4),     createBun(5),   ] } <\/code><\/pre>\n
\u041a\u0430\u043a \u0432\u0438\u0434\u043d\u043e, \u043d\u043e\u043c\u0435\u0440 \u043f\u043e\u0440\u0442\u0430 \u0434\u043b\u044f \u043e\u0440\u043a\u0435\u0441\u0442\u0440\u0430\u0446\u0438\u0438 \u043c\u044b \u043f\u0435\u0440\u0435\u0434\u0430\u0435\u043c \u0447\u0435\u0440\u0435\u0437 \u0430\u0440\u0433\u0443\u043c\u0435\u043d\u0442\u044b \u043a\u043e\u043c\u0430\u043d\u0434\u043d\u043e\u0439 \u0441\u0442\u0440\u043e\u043a\u0438. \u041d\u0430\u0438\u0431\u043e\u043b\u0435\u0435 \u0443\u0434\u043e\u0431\u043d\u043e, \u0442\u0430\u043a \u043a\u0430\u043a \u0444\u0430\u0439\u043b .env<\/code> \u043e\u0441\u0442\u0430\u0435\u0442\u0441\u044f \u0441\u0442\u0430\u0442\u0438\u0447\u043d\u044b\u043c \u0431\u0435\u0437 \u0438\u0437\u043c\u0435\u043d\u0435\u043d\u0438\u044f \u0432 \u0440\u0430\u043d\u0442\u0430\u0439\u043c\u0435. \u0414\u043b\u044f \u0437\u0430\u043f\u0443\u0441\u043a\u0430 \u043f\u0440\u043e\u0435\u043a\u0442\u0430 \u043c\u044b \u0438\u0441\u043f\u043e\u043b\u044c\u0443\u0435\u043c Bun <\/a>— \u0443\u0441\u043a\u043e\u0440\u0435\u043d\u043d\u044b\u0439 \u0430\u043d\u0430\u043b\u043e\u0433 NodeJS \u043f\u043e \u0441\u043a\u043e\u0440\u043e\u0441\u0442\u0438 \u0441\u043e\u043f\u043e\u0441\u0442\u0430\u0432\u0438\u043c\u044b\u0439 \u0441 Golang<\/p>\n
\u0420\u043e\u0439 \u0430\u0433\u0435\u043d\u0442\u043e\u0432<\/h3>\n
\u0410\u0433\u0435\u043d\u0442 — \u0430\u043d\u0430\u043b\u043e\u0433 \u0441\u0446\u0435\u043d\u044b \u0432 telegraf, \u043c\u043e\u0434\u0435\u043b\u044c LLM, \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044f\u0449\u0430\u044f \u0438\u0437\u043e\u043b\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u0439 system prompt. \u0422\u0435\u043a\u0443\u0449\u0438\u0439 \u0430\u0433\u0435\u043d\u0442 \u0432 Swarm \u043c\u043e\u0436\u0435\u0442 \u0431\u044b\u0442\u044c \u0438\u0437\u043c\u0435\u043d\u0435\u043d \u0447\u0435\u0440\u0435\u0437 \u0432\u044b\u0437\u043e\u0432 \u0444\u0443\u043d\u043a\u0446\u0438\u0438 changeToAgent <\/code>— \u0430\u043d\u0430\u043b\u043e\u0433 \u043d\u0430\u0432\u0438\u0433\u0430\u0446\u0438\u0438 \u043f\u043e \u0441\u0446\u0435\u043d\u0430\u043c \u0432 \u0442\u0435\u043b\u0435\u0433\u0440\u0430\u043c \u0431\u043e\u0442\u0435 \u043f\u043e\u0441\u043b\u0435 \u043a\u043b\u0438\u043a\u0430 \u043f\u043e \u043a\u043d\u043e\u043f\u043a\u0435<\/p>\n
import { Adapter, addAgent, addCompletion, addSwarm } from \"agent-swarm-kit\"; import { OpenAI } from \"openai\";  export const OPENAI_COMPLETION = addCompletion({   completionName: \"openai_completion\",   getCompletion: Adapter.fromOpenAI(new OpenAI({ apiKey: process.env.OPENAI_API_KEY })) });  export const TEST_AGENT = addAgent({   docDescription: \"This agent operates within the nginx-balancer-chat project as a test agent, utilizing the OpenaiCompletion to inform users about the actual server port of one of 5 chat instances running on different ports and upstreamed by Nginx to port 80, extracting the port details from the chat history\u2019s system message.\",   agentName: \"test_agent\",   completion: OPENAI_COMPLETION,   prompt: `You are a test agent for Nginx Upstream. Tell user the server port from the chat history (system message)`,   dependsOn: [], });  export const TEST_SWARM = addSwarm({   docDescription: \"This swarm serves as the core structure for the nginx-balancer-chat project, managing a single TestAgent as both the sole member and default agent to handle user interactions, leveraging the CohereCompletion to report the specific port of one of 5 upstreamed chat instances balanced by Nginx to port 80.\",   swarmName: \"test_swarm\",   agentList: [TEST_AGENT],   defaultAgent: TEST_AGENT, }); <\/code><\/pre>\n
\u041a\u043e\u0434 \u044d\u0442\u043e\u0433\u043e \u043f\u0440\u0438\u043c\u0435\u0440\u0430 \u0437\u0430\u043f\u0440\u043e\u0433\u0440\u0430\u043c\u043c\u0438\u0440\u043e\u0432\u0430\u043d \u0442\u0430\u043a, \u0447\u0442\u043e\u0431\u044b LLM \u043c\u043e\u0434\u0435\u043b\u044c \u043d\u0430\u0437\u0432\u0430\u043b\u0430, \u0441 \u043a\u0430\u043a\u043e\u0433\u043e \u043f\u043e\u0440\u0442\u0430 \u0431\u044b\u043b \u043f\u0440\u043e\u043a\u0441\u0438\u0440\u043e\u0432\u0430\u043d \u0437\u0430\u043f\u0440\u043e\u0441 WebSocket. \u0412\u043c\u0435\u0441\u0442\u043e OPENAI_COMPLETION <\/code>\u0434\u043b\u044f \u043a\u0430\u0436\u0434\u043e\u0433\u043e \u0430\u0433\u0435\u043d\u0442\u0430 \u043f\u043e \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u0438 \u043c\u043e\u0436\u043d\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c LMStudio<\/code>, Ollama<\/code>, Cohere<\/code>, \u0431\u043e\u043b\u0435\u0435 \u043f\u043e\u0434\u0440\u043e\u0431\u043d\u0435\u0435 \u0432 \u0440\u0435\u043f\u043e<\/p>\n
import { Chat, getAgentName, Schema, History } from \"agent-swarm-kit\"; import type { ServerWebSocket } from \"bun\"; import { parseArgs } from \"util\"; import { TEST_SWARM } from \".\/lib\/swarm\";  declare function parseInt(value: unknown): number;  type WebSocketData = {   clientId: string; };  const { values } = parseArgs({   args: process.argv,   options: {     server: {       type: \"boolean\",     },     port: {       type: \"string\",     },   },   strict: true,   allowPositionals: true, });   History.useHistoryCallbacks({   getSystemPrompt: () => [     `The server port is ${SERVER_PORT}. Tell him that port ASAP`   ] });  const SERVER_PORT = parseInt(values.port);  if (isNaN(SERVER_PORT)) {   throw new Error(`Server port is not a number: ${values.port}`); }  if (values.server) {   Bun.serve({     fetch(req, server) {       const clientId = new URL(req.url).searchParams.get(\"clientId\")!;       if (!clientId) {         return new Response(\"Invalid clientId\", { status: 500 });       }       console.log(`Connected clientId=${clientId} port=${SERVER_PORT}`);       server.upgrade<WebSocketData>(req, {         data: {           clientId,         },       });     },     websocket: {       async open(ws: ServerWebSocket<WebSocketData>) {         await Chat.beginChat(ws.data.clientId, TEST_SWARM);         await Schema.writeSessionMemory(ws.data.clientId, { port: SERVER_PORT });       },       async message(ws: ServerWebSocket<WebSocketData>, message: string) {         const answer = await Chat.sendMessage(ws.data.clientId, message, TEST_SWARM);         ws.send(           JSON.stringify({             data: answer,             agentName: await getAgentName(ws.data.clientId),           })         );       },       async close(ws: ServerWebSocket<WebSocketData>) {         console.log(`Disconnected clientId=${ws.data.clientId} port=${SERVER_PORT}`);         await Chat.dispose(ws.data.clientId, TEST_SWARM);       },     },     port: SERVER_PORT,   }); }  console.log(`Server listening http:\/\/localhost:${SERVER_PORT}`) <\/code><\/pre>\n
\u0415\u0441\u043b\u0438 \u0438\u043d\u0442\u0435\u0440\u0435\u0441\u0443\u0435\u0442 \u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u043a\u0430 \u0447\u0430\u0442\u043e\u0432 \u0441 \u0431\u043e\u043b\u0435\u0435 \u0447\u0435\u043c \u043e\u0434\u043d\u0438\u043c \u0430\u0433\u0435\u043d\u0442\u043e\u043c, \u043f\u043e\u0441\u043c\u043e\u0442\u0440\u0438\u0442\u0435 \u0434\u043e\u043a\u0443\u043c\u0435\u043d\u0442\u0430\u0446\u0438\u044f<\/a><\/p>\n
\u0421\u043f\u0430\u0441\u0438\u0431\u043e \u0437\u0430 \u0432\u043d\u0438\u043c\u0430\u043d\u0438\u0435!<\/h2>\n<\/p>\n<\/div>\n<\/div>\n<\/div>\n
<\/div>\n

 \u0441\u0441\u044b\u043b\u043a\u0430 \u043d\u0430 \u043e\u0440\u0438\u0433\u0438\u043d\u0430\u043b \u0441\u0442\u0430\u0442\u044c\u0438  https:\/\/habr.com\/ru\/articles\/896222\/<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"
<\/div>\n
\n
\n
\n
\n
\n
\u0418\u0441\u0445\u043e\u0434\u043d\u044b\u0439 \u043a\u043e\u0434, \u0440\u0430\u0437\u043e\u0431\u0440\u0430\u043d\u043d\u044b\u0439 \u0432 \u0441\u0442\u0430\u0442\u044c\u0435, \u043e\u043f\u0443\u0431\u043b\u0438\u043a\u043e\u0432\u0430\u043d \u0432 \u044d\u0442\u043e\u043c \u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u0438<\/a><\/p>\n<\/blockquote>\n
\u0412 \u0438\u043d\u0442\u0435\u0440\u043d\u0435\u0442\u0435 \u0441\u0443\u0449\u0435\u0441\u0442\u0432\u0443\u0435\u0442 \u043c\u043d\u043e\u0436\u0435\u0441\u0442\u0432\u043e \u043f\u0440\u0438\u043c\u0435\u0440\u043e\u0432, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u044e\u0442 \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0438\u0442\u044c ChatGPT 3.5 \u0431\u0435\u0437 \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442\u043e\u0432 \u043a \u0442\u0435\u043b\u0435\u0433\u0440\u0430\u043c \u0431\u043e\u0442\u0443. \u041e\u0434\u043d\u0430\u043a\u043e, \u043a\u043e\u0433\u0434\u0430 \u0440\u0435\u0447\u044c \u0437\u0430\u0445\u043e\u0434\u0438\u0442 \u043e \u0431\u043e\u043b\u044c\u0448\u043e\u043c \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u0435 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u0435\u0439, \u043d\u0435 \u0441\u0443\u0449\u0435\u0441\u0442\u0432\u0443\u044e\u0442 \u043f\u0440\u0438\u043c\u0435\u0440\u043e\u0432 \u0440\u0430\u0441\u043f\u0440\u0435\u0434\u0435\u043b\u0435\u043d\u0438\u044f \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438 \u043f\u043e \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u0438\u043c \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u0430\u043c: \u0432\u0441\u0435 \u0442\u0443\u0442\u043e\u0440\u0438\u0430\u043b\u044b \u0432 \u0438\u043d\u0442\u0435\u0440\u043d\u0435\u0442\u0435 \u0437\u0430\u043f\u0443\u0441\u043a\u0430\u044e\u0442 \u043c\u043e\u043d\u043e\u043b\u0438\u0442 \u0441 \u043e\u0434\u043d\u043e\u0439 \u0440\u0435\u043f\u043b\u0438\u043a\u043e\u0439<\/p>\n
\n
https:\/\/github.com\/telegraf\/telegraf\/issues\/423<\/a><\/figcaption><\/div>\n<\/figure>\n
\u0422\u0430\u043a \u0436\u0435, \u043d\u0430 \u043f\u0440\u0430\u043a\u0442\u0438\u043a\u0435 \u0440\u0430\u0431\u043e\u0442\u044b \u0441 NodeJS, \u044f \u0441\u0442\u0430\u043b\u043a\u0438\u0432\u0430\u043b\u0441\u044f \u0441 \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u043e\u0439, \u043a\u043e\u0433\u0434\u0430 \u043c\u043d\u043e\u0433\u043e Promise \u0432 \u0441\u0442\u0430\u0442\u0443\u0441\u0435 pending<\/a> \u0437\u0430\u043c\u0435\u0434\u043b\u044f\u044e\u0442 \u0440\u0430\u0431\u043e\u0442\u0443 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u043e\u0439 \u043d\u0430 \u0441\u0431\u043e\u0440\u0449\u0438\u043a \u043c\u0443\u0441\u043e\u0440\u0430. \u0414\u043e\u0431\u0430\u0432\u0438\u0432 \u0441\u0442\u043e\u0440\u043e\u043d\u043d\u0438\u0435 \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442\u044b<\/a> (\u0434\u0430\u0432 ChatGPT \u0432\u044b\u0437\u044b\u0432\u0430\u0442\u044c \u0432\u043d\u0435\u0448\u043d\u0438\u0438 \u0444\u0443\u043d\u043a\u0446\u0438\u0438 \u0441 \u0437\u0430\u043f\u0440\u043e\u0441\u0430\u043c\u0438 \u043a \u0431\u0430\u0437\u0435 \u0434\u0430\u043d\u043d\u044b\u0445) \u043f\u043e\u0442\u0440\u0435\u0431\u0443\u0435\u0442\u0441\u044f \u0434\u0443\u043c\u0430\u0442\u044c \u043a\u0430\u043a \u043c\u0438\u043d\u0438\u043c\u0443\u043c \u043e \u0441\u043e\u0437\u0434\u0430\u043d\u0438\u0438 \u0440\u0435\u043f\u043b\u0438\u043a \u043c\u043e\u043d\u043e\u043b\u0438\u0442\u0430, \u0447\u0442\u043e\u0431\u044b \u0440\u0430\u0437\u0434\u0443\u0432\u0430\u043d\u0438\u044f \u043e\u0447\u0435\u0440\u0435\u0434\u0438 \u043e\u0436\u0438\u0434\u0430\u043d\u0438\u044f \u0434\u0430\u043d\u043d\u044b\u0445 \u0438\u0437 \u0431\u0430\u0437\u044b<\/p>\n
\u0410\u0440\u0445\u0438\u0442\u0435\u043a\u0442\u0443\u0440\u0430 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f<\/h2>\n
\u0414\u043b\u044f \u0431\u0430\u043b\u0430\u043d\u0441\u0438\u0440\u043e\u0432\u043a\u0438 \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438 \u0441\u0430\u043c\u044b\u043c \u043e\u0447\u0435\u0432\u0438\u0434\u043d\u044b\u043c \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442\u043e\u043c \u044f\u0432\u043b\u044f\u0435\u0442\u0441\u044f Nginx upstream<\/a> —  \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442 \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u0442 WebSocket \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435 \u043d\u043e\u0432\u043e\u0433\u043e \u043a\u043b\u0438\u0435\u043d\u0442\u0430 \u043d\u0430 \u043f\u043e\u0440\u0442 80 \u0438 \u0432 \u043f\u043e\u0440\u044f\u0434\u043a\u0435 \u043e\u0447\u0435\u0440\u0435\u0434\u0438 \u043f\u0440\u043e\u043a\u0441\u0438\u0440\u0443\u0435\u0442 \u0435\u0433\u043e \u043d\u0430 8081, 8082, …, 8085 \u0437\u0430\u0432\u0438\u0441\u0438\u043c\u043e \u043e\u0442 \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u0430 \u0440\u0435\u043f\u043b\u0438\u043a. \u0415\u0441\u043b\u0438 \u043a\u043b\u0438\u0435\u043d\u0442 \u043d\u0435 \u043f\u0440\u043e\u044f\u0432\u043b\u044f\u0435\u0442 \u0430\u043a\u0442\u0438\u0432\u043d\u043e\u0441\u0442\u044c 15 \u043c\u0438\u043d\u0443\u0442, \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435 \u043f\u0440\u0438\u0440\u044b\u0432\u0430\u0435\u0442\u0441\u044f, \u0435\u0441\u043b\u0438 \u0431\u0443\u0434\u0435\u0442 \u043d\u043e\u0432\u043e\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435, \u043e\u043d\u043e \u0441\u043e\u0437\u0434\u0430\u0441\u0442\u0441\u044f \u0437\u0430\u043d\u043e\u0433\u043e.<\/p>\n
\n
https:\/\/nginx.org\/en\/docs\/http\/ngx_http_upstream_module.html<\/a><\/figcaption><\/div>\n<\/figure>\n
\u0420\u0435\u043f\u043b\u0438\u043a\u0438 \u0441\u043e\u0445\u0440\u0430\u043d\u044f\u044e\u0442 \u0438\u0441\u0442\u043e\u0440\u0438\u044e \u043f\u0435\u0440\u0435\u043f\u0438\u0441\u043a\u0438 \u0432 Redis, \u0447\u0442\u043e \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0435\u0442 \u0432\u043e\u0441\u0441\u043e\u0437\u0434\u0430\u0442\u044c \u043a\u043e\u043d\u0442\u0435\u043a\u0441\u0442 \u043d\u0435 \u0441\u043c\u043e\u0442\u0440\u044f \u043d\u0430 \u0442\u043e, \u0447\u0442\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0435\u0442 \u043d\u043e\u0432\u044b\u0439 \u043f\u0440\u043e\u0446\u0435\u0441\u0441. \u0421\u043e\u0437\u0434\u0430\u0432\u0430\u0442\u044c \u0440\u0435\u043f\u043b\u0438\u043a\u0438 \u0431\u0443\u0434\u0435\u0442 PM2 <\/a>— \u043d\u0430\u0438\u0431\u043e\u043b\u0435\u0435 \u043d\u0430\u0442\u0438\u0432\u043d\u044b\u0439 \u0441\u043f\u043e\u0441\u043e\u0431 \u0434\u043b\u044f \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0439 \u0441\u0442\u0435\u043a\u0430 NodeJS<\/p>\n
\n
https:\/\/pm2.io\/docs\/plus\/overview\/<\/a><\/figcaption><\/div>\n<\/figure>\n
\u0422\u0430\u043a \u0436\u0435, \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044f PM2, \u0437\u0430 40$ \u0432 \u043c\u0435\u0441\u044f\u0446 \u043c\u043e\u0436\u043d\u043e \u043a\u0443\u043f\u0438\u0442\u044c \u0433\u043e\u0442\u043e\u0432\u043e\u0435 \u0443\u0432\u0435\u0434\u043e\u043c\u043b\u0435\u043d\u0438\u0435 \u043e \u0438\u043d\u0446\u0438\u0434\u0435\u043d\u0442\u0430\u0445 \u043f\u043e Slack \/ Email, \u043c\u043e\u043d\u0438\u0442\u043e\u0440\u0438\u043d\u0433 \u0441\u0435\u0440\u0432\u0435\u0440\u0430 \u043f\u043e \u0441\u0442\u0430\u043d\u0434\u0430\u0440\u0442\u043d\u044b\u043c \u043c\u0435\u0442\u0440\u0438\u043a\u0430\u043c \u0442\u0430\u043a\u0438\u043c \u043a\u0430\u043a CPUs: cores, hardware threads, virtual threads, Memory: capacity, Network interfaces, Storage devices: I\/O, capacity, \u0432\u0440\u0435\u043c\u044f \u043e\u0442\u043a\u043b\u0438\u043a\u0430 \u0438 \u0442\u0434. \u042d\u0442\u043e \u044d\u043a\u043e\u043d\u043e\u043c\u0438\u0442 \u0434\u0435\u043d\u044c\u0433\u0438 \u043d\u0430 Dev Ops \u0434\u043e \u0441\u0430\u043c\u043e\u043e\u043a\u0443\u043f\u0430\u0435\u043c\u043e\u0441\u0442\u0438 \u043f\u0440\u043e\u0435\u043a\u0442\u0430.<\/p>\n
\u0424\u0430\u0439\u043b\u044b \u043a\u043e\u043d\u0444\u0438\u0433\u0443\u0440\u0430\u0446\u0438\u0438<\/h2>\n
\u0427\u0442\u043e\u0431\u044b \u043d\u0435 \u0441\u043f\u0435\u0446\u0438\u0430\u043b\u0438\u0437\u0438\u0440\u043e\u0432\u0430\u0442\u044c Linux \u043d\u0430 \u043c\u0430\u0448\u0438\u043d\u0435 \u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a\u0430 \u043f\u043e\u0434 \u043e\u0434\u0438\u043d \u043f\u0440\u043e\u0435\u043a\u0442, \u043e\u0431\u0435\u0440\u043d\u0435\u043c Nginx \u0432 Docker. \u0414\u043b\u044f \u044d\u0442\u043e\u0433\u043e, \u043d\u0430\u043f\u0438\u0448\u0435\u043c docker-compose.yaml<\/code><\/p>\n
version: '3.8'  services:   nginx:     image: nginx:1.27.4     ports:       - \"80:80\"     extra_hosts:       - \"host.docker.internal:host-gateway\"     volumes:       - .\/config\/nginx.conf:\/etc\/nginx\/nginx.conf:ro       - .\/logs\/nginx:\/var\/log\/nginx <\/code><\/pre>\n
\u0418 \u0441\u043e\u0437\u0434\u0430\u0434\u0438\u043c \u0441\u043e\u043f\u0443\u0442\u0441\u0442\u0432\u0443\u044e\u0449\u0438\u0439 .\/config\/nginx.config<\/code> \u0441 \u043f\u0435\u0440\u0435\u0447\u0438\u0441\u043b\u0435\u043d\u0438\u0435\u043c \u0440\u0435\u043f\u043b\u0438\u043a<\/p>\n
user nginx; worker_processes auto;  error_log \/var\/log\/nginx\/error.log warn; pid \/var\/run\/nginx.pid;  events {     worker_connections 1024;     use epoll;     multi_accept on; }  http {     include \/etc\/nginx\/mime.types;     default_type application\/octet-stream;      log_format main '$remote_addr - $remote_user [$time_local] \"$request\" '                     '$status $body_bytes_sent \"$http_referer\" '                     '\"$http_user_agent\" \"$http_x_forwarded_for\"';      access_log \/var\/log\/nginx\/access.log main;      upstream local_websocket_servers {         server host.docker.internal:8081;  # Using host.docker.internal from hosts shared from host machine         server host.docker.internal:8082;         server host.docker.internal:8083;         server host.docker.internal:8084;         server host.docker.internal:8085;         least_conn;     }      map $http_upgrade $connection_upgrade {         default upgrade;         ''      close;     }      server {         listen 80;         server_name localhost;          location \/ {             proxy_pass http:\/\/local_websocket_servers$is_args$args;                          # WebSocket-specific headers             proxy_http_version 1.1;             proxy_set_header Upgrade $http_upgrade;             proxy_set_header Connection $connection_upgrade;                          # Preserve original headers and connection details             proxy_set_header Host $host;             proxy_set_header X-Real-IP $remote_addr;             proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;             proxy_set_header X-Forwarded-Proto $scheme;              # Close upstream if client disconnects             proxy_ignore_client_abort on;                          # Long-lived connection settings             proxy_read_timeout 86400s;             proxy_send_timeout 86400s;                          # Buffer and performance settings             proxy_buffer_size 128k;             proxy_buffers 4 256k;             proxy_busy_buffers_size 256k;         }     } } <\/code><\/pre>\n
\u0414\u043b\u044f \u0437\u0430\u043f\u0443\u0441\u043a\u0430 \u0440\u0435\u043f\u043b\u0438\u043a \u0447\u0435\u0440\u0435\u0437 pm2 \u0441\u043e\u0437\u0434\u0430\u0434\u0438\u043c pm2.config.cjs<\/code>. \u041f\u043e \u0441\u0441\u044b\u043b\u043a\u0435 \u043b\u0435\u0436\u0438\u0442 package.json<\/a> \u0441 \u0441\u043a\u0440\u0438\u043f\u0442\u0430\u043c\u0438 \u0434\u043b\u044f \u0437\u0430\u043f\u0443\u0441\u043a\u0430 \u043f\u0440\u043e\u0435\u043a\u0442\u0430 \u0447\u0435\u0440\u0435\u0437 npm start<\/code><\/p>\n
const path = require(\"path\"); const os = require(\"os\"); const dotenv = require('dotenv');  const readConfig = () => dotenv.parse(\".\/.env\");  const getPath = (unixPath) => {   return path.resolve(unixPath.replace('~', os.homedir())); };  const createBun = (index) => ({   name: `bun-ws-${index}`,   script: \".\/src\/server.ts\",   interpreter: getPath(\"~\/.bun\/bin\/bun\"),   args: [\"--server\", `--port=808${index}`],   out_file: `.\/logs\/pm2\/bun-ws-${index}-out.log`,   error_file: `.\/logs\/pm2\/bun-ws-${index}-error.log`,   log_date_format: \"YYYY-MM-DD HH:mm:ss\",   merge_logs: true,   env: readConfig(), });  module.exports = {   apps: [     \/*     {       name: \"bun-ws-1\",       script: \".\/src\/server.ts\",       interpreter: getPath(\"~\/.bun\/bin\/bun\"),       args: [\"--server\", \"--port=8081\"],       out_file: \".\/logs\/pm2\/bun-ws-1-out.log\",       error_file: \".\/logs\/pm2\/bun-ws-1-error.log\",       log_date_format: \"YYYY-MM-DD HH:mm:ss\",       merge_logs: true,     },     *\/     createBun(1),     createBun(2),     createBun(3),     createBun(4),     createBun(5),   ] } <\/code><\/pre>\n
\u041a\u0430\u043a \u0432\u0438\u0434\u043d\u043e, \u043d\u043e\u043c\u0435\u0440 \u043f\u043e\u0440\u0442\u0430 \u0434\u043b\u044f \u043e\u0440\u043a\u0435\u0441\u0442\u0440\u0430\u0446\u0438\u0438 \u043c\u044b \u043f\u0435\u0440\u0435\u0434\u0430\u0435\u043c \u0447\u0435\u0440\u0435\u0437 \u0430\u0440\u0433\u0443\u043c\u0435\u043d\u0442\u044b \u043a\u043e\u043c\u0430\u043d\u0434\u043d\u043e\u0439 \u0441\u0442\u0440\u043e\u043a\u0438. \u041d\u0430\u0438\u0431\u043e\u043b\u0435\u0435 \u0443\u0434\u043e\u0431\u043d\u043e, \u0442\u0430\u043a \u043a\u0430\u043a \u0444\u0430\u0439\u043b .env<\/code> \u043e\u0441\u0442\u0430\u0435\u0442\u0441\u044f \u0441\u0442\u0430\u0442\u0438\u0447\u043d\u044b\u043c \u0431\u0435\u0437 \u0438\u0437\u043c\u0435\u043d\u0435\u043d\u0438\u044f \u0432 \u0440\u0430\u043d\u0442\u0430\u0439\u043c\u0435. \u0414\u043b\u044f \u0437\u0430\u043f\u0443\u0441\u043a\u0430 \u043f\u0440\u043e\u0435\u043a\u0442\u0430 \u043c\u044b \u0438\u0441\u043f\u043e\u043b\u044c\u0443\u0435\u043c Bun <\/a>— \u0443\u0441\u043a\u043e\u0440\u0435\u043d\u043d\u044b\u0439 \u0430\u043d\u0430\u043b\u043e\u0433 NodeJS \u043f\u043e \u0441\u043a\u043e\u0440\u043e\u0441\u0442\u0438 \u0441\u043e\u043f\u043e\u0441\u0442\u0430\u0432\u0438\u043c\u044b\u0439 \u0441 Golang<\/p>\n
\u0420\u043e\u0439 \u0430\u0433\u0435\u043d\u0442\u043e\u0432<\/h3>\n
\u0410\u0433\u0435\u043d\u0442 — \u0430\u043d\u0430\u043b\u043e\u0433 \u0441\u0446\u0435\u043d\u044b \u0432 telegraf, \u043c\u043e\u0434\u0435\u043b\u044c LLM, \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044f\u0449\u0430\u044f \u0438\u0437\u043e\u043b\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u0439 system prompt. \u0422\u0435\u043a\u0443\u0449\u0438\u0439 \u0430\u0433\u0435\u043d\u0442 \u0432 Swarm \u043c\u043e\u0436\u0435\u0442 \u0431\u044b\u0442\u044c \u0438\u0437\u043c\u0435\u043d\u0435\u043d \u0447\u0435\u0440\u0435\u0437 \u0432\u044b\u0437\u043e\u0432 \u0444\u0443\u043d\u043a\u0446\u0438\u0438 changeToAgent <\/code>— \u0430\u043d\u0430\u043b\u043e\u0433 \u043d\u0430\u0432\u0438\u0433\u0430\u0446\u0438\u0438 \u043f\u043e \u0441\u0446\u0435\u043d\u0430\u043c \u0432 \u0442\u0435\u043b\u0435\u0433\u0440\u0430\u043c \u0431\u043e\u0442\u0435 \u043f\u043e\u0441\u043b\u0435 \u043a\u043b\u0438\u043a\u0430 \u043f\u043e \u043a\u043d\u043e\u043f\u043a\u0435<\/p>\n
import { Adapter, addAgent, addCompletion, addSwarm } from \"agent-swarm-kit\"; import { OpenAI } from \"openai\";  export const OPENAI_COMPLETION = addCompletion({   completionName: \"openai_completion\",   getCompletion: Adapter.fromOpenAI(new OpenAI({ apiKey: process.env.OPENAI_API_KEY })) });  export const TEST_AGENT = addAgent({   docDescription: \"This agent operates within the nginx-balancer-chat project as a test agent, utilizing the OpenaiCompletion to inform users about the actual server port of one of 5 chat instances running on different ports and upstreamed by Nginx to port 80, extracting the port details from the chat history\u2019s system message.\",   agentName: \"test_agent\",   completion: OPENAI_COMPLETION,   prompt: `You are a test agent for Nginx Upstream. Tell user the server port from the chat history (system message)`,   dependsOn: [], });  export const TEST_SWARM = addSwarm({   docDescription: \"This swarm serves as the core structure for the nginx-balancer-chat project, managing a single TestAgent as both the sole member and default agent to handle user interactions, leveraging the CohereCompletion to report the specific port of one of 5 upstreamed chat instances balanced by Nginx to port 80.\",   swarmName: \"test_swarm\",   agentList: [TEST_AGENT],   defaultAgent: TEST_AGENT, }); <\/code><\/pre>\n
\u041a\u043e\u0434 \u044d\u0442\u043e\u0433\u043e \u043f\u0440\u0438\u043c\u0435\u0440\u0430 \u0437\u0430\u043f\u0440\u043e\u0433\u0440\u0430\u043c\u043c\u0438\u0440\u043e\u0432\u0430\u043d \u0442\u0430\u043a, \u0447\u0442\u043e\u0431\u044b LLM \u043c\u043e\u0434\u0435\u043b\u044c \u043d\u0430\u0437\u0432\u0430\u043b\u0430, \u0441 \u043a\u0430\u043a\u043e\u0433\u043e \u043f\u043e\u0440\u0442\u0430 \u0431\u044b\u043b \u043f\u0440\u043e\u043a\u0441\u0438\u0440\u043e\u0432\u0430\u043d \u0437\u0430\u043f\u0440\u043e\u0441 WebSocket. \u0412\u043c\u0435\u0441\u0442\u043e OPENAI_COMPLETION <\/code>\u0434\u043b\u044f \u043a\u0430\u0436\u0434\u043e\u0433\u043e \u0430\u0433\u0435\u043d\u0442\u0430 \u043f\u043e \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u0438 \u043c\u043e\u0436\u043d\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c LMStudio<\/code>, Ollama<\/code>, Cohere<\/code>, \u0431\u043e\u043b\u0435\u0435 \u043f\u043e\u0434\u0440\u043e\u0431\u043d\u0435\u0435 \u0432 \u0440\u0435\u043f\u043e<\/p>\n
import { Chat, getAgentName, Schema, History } from \"agent-swarm-kit\"; import type { ServerWebSocket } from \"bun\"; import { parseArgs } from \"util\"; import { TEST_SWARM } from \".\/lib\/swarm\";  declare function parseInt(value: unknown): number;  type WebSocketData = {   clientId: string; };  const { values } = parseArgs({   args: process.argv,   options: {     server: {       type: \"boolean\",     },     port: {       type: \"string\",     },   },   strict: true,   allowPositionals: true, });   History.useHistoryCallbacks({   getSystemPrompt: () => [     `The server port is ${SERVER_PORT}. Tell him that port ASAP`   ] });  const SERVER_PORT = parseInt(values.port);  if (isNaN(SERVER_PORT)) {   throw new Error(`Server port is not a number: ${values.port}`); }  if (values.server) {   Bun.serve({     fetch(req, server) {       const clientId = new URL(req.url).searchParams.get(\"clientId\")!;       if (!clientId) {         return new Response(\"Invalid clientId\", { status: 500 });       }       console.log(`Connected clientId=${clientId} port=${SERVER_PORT}`);       server.upgrade<WebSocketData>(req, {         data: {           clientId,         },       });     },     websocket: {       async open(ws: ServerWebSocket<WebSocketData>) {         await Chat.beginChat(ws.data.clientId, TEST_SWARM);         await Schema.writeSessionMemory(ws.data.clientId, { port: SERVER_PORT });       },       async message(ws: ServerWebSocket<WebSocketData>, message: string) {         const answer = await Chat.sendMessage(ws.data.clientId, message, TEST_SWARM);         ws.send(           JSON.stringify({             data: answer,             agentName: await getAgentName(ws.data.clientId),           })         );       },       async close(ws: ServerWebSocket<WebSocketData>) {         console.log(`Disconnected clientId=${ws.data.clientId} port=${SERVER_PORT}`);         await Chat.dispose(ws.data.clientId, TEST_SWARM);       },     },     port: SERVER_PORT,   }); }  console.log(`Server listening http:\/\/localhost:${SERVER_PORT}`) <\/code><\/pre>\n
\u0415\u0441\u043b\u0438 \u0438\u043d\u0442\u0435\u0440\u0435\u0441\u0443\u0435\u0442 \u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u043a\u0430 \u0447\u0430\u0442\u043e\u0432 \u0441 \u0431\u043e\u043b\u0435\u0435 \u0447\u0435\u043c \u043e\u0434\u043d\u0438\u043c \u0430\u0433\u0435\u043d\u0442\u043e\u043c, \u043f\u043e\u0441\u043c\u043e\u0442\u0440\u0438\u0442\u0435 \u0434\u043e\u043a\u0443\u043c\u0435\u043d\u0442\u0430\u0446\u0438\u044f<\/a><\/p>\n
\u0421\u043f\u0430\u0441\u0438\u0431\u043e \u0437\u0430 \u0432\u043d\u0438\u043c\u0430\u043d\u0438\u0435!<\/h2>\n<\/p>\n<\/div>\n<\/div>\n<\/div>\n
<\/div>\n

 \u0441\u0441\u044b\u043b\u043a\u0430 \u043d\u0430 \u043e\u0440\u0438\u0433\u0438\u043d\u0430\u043b \u0441\u0442\u0430\u0442\u044c\u0438  https:\/\/habr.com\/ru\/articles\/896222\/<\/a>
<\/br><\/br><\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[],"tags":[],"class_list":["post-454346","post","type-post","status-publish","format-standard","hentry"],"_links":{"self":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/454346","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=454346"}],"version-history":[{"count":0,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/454346\/revisions"}],"wp:attachment":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=454346"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=454346"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=454346"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}