{"id":481425,"date":"2026-05-28T14:09:07","date_gmt":"2026-05-28T14:09:07","guid":{"rendered":"https:\/\/savepearlharbor.com\/?p=481425"},"modified":"-0001-11-30T00:00:00","modified_gmt":"-0001-11-29T21:00:00","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=481425","title":{"rendered":"\u0421\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u043e\u0435 \u043b\u043e\u0433\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0435 \u0438 \u0442\u0440\u0435\u0439\u0441\u0438\u043d\u0433 \u0432 Node.js: @cleverbrush\/log \u0438 @cleverbrush\/otel"},"content":{"rendered":"
\n

\u0421\u0442\u0430\u0442\u044c\u044f \u043e \u0442\u043e\u043c, \u043a\u0430\u043a \u043f\u043e\u043b\u0443\u0447\u0438\u0442\u044c \u043d\u0430\u0431\u043b\u044e\u0434\u0430\u0435\u043c\u043e\u0441\u0442\u044c (observability) \u0432 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0438 \u0441 \u043c\u0438\u043d\u0438\u043c\u0430\u043b\u044c\u043d\u044b\u043c \u043a\u043e\u0434\u043e\u043c, \u0430 \u0431\u043e\u043d\u0443\u0441\u043e\u043c \u043f\u043e\u043b\u0443\u0447\u0438\u0442\u044c \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u0435 \u043b\u043e\u0433\u0438 \u0441 \u0442\u0438\u043f\u0438\u0437\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u043c\u0438 \u0448\u0430\u0431\u043b\u043e\u043d\u0430\u043c\u0438, \u0430\u0432\u0442\u043e\u043c\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0443\u044e \u043a\u043e\u0440\u0440\u0435\u043b\u044f\u0446\u0438\u044e \u0441\u043e \u0441\u043f\u0430\u043d\u0430\u043c\u0438 OpenTelemetry, \u0432\u0441\u0451 \u044d\u0442\u043e \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e \u043d\u0430\u0431\u043e\u0440\u0430 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u044f \u043d\u0430\u0437\u044b\u0432\u0430\u044e CleverBrush Framework.<\/p>\n

\u0412\u0441\u0435 \u043f\u0440\u0438\u043c\u0435\u0440\u044b \u043d\u0438\u0436\u0435 \u0432\u0437\u044f\u0442\u044b \u0438\u0437 xpenser<\/a> \u2014 open-source \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f \u0434\u043b\u044f \u0443\u0447\u0451\u0442\u0430 \u043b\u0438\u0447\u043d\u044b\u0445 \u0434\u043e\u0445\u043e\u0434\u043e\u0432 \u0438 \u0440\u0430\u0441\u0445\u043e\u0434\u043e\u0432. \u0421 \u043e\u0434\u043d\u043e\u0439 \u0441\u0442\u043e\u0440\u043e\u043d\u044b, \u044d\u0442\u043e \u0434\u0435\u043c\u043e\u043d\u0441\u0442\u0440\u0430\u0442\u043e\u0440 \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e\u0441\u0442\u0435\u0439 Cleverbrush Framework, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u044f \u0441\u0434\u0435\u043b\u0430\u043b \u0434\u043b\u044f \u043f\u0440\u043e\u0432\u0435\u0440\u043a\u0438 \u043d\u0430 \u043f\u0440\u0430\u043a\u0442\u0438\u043a\u0435 \u0432\u0441\u0435\u0439 \u043c\u0430\u0448\u0438\u043d\u0435\u0440\u0438\u0438, \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u0435\u0441\u0442\u044c \u0432 \u0444\u0440\u0435\u0439\u043c\u0432\u043e\u0440\u043a\u0435, \u0442\u0430\u043a\u043e\u0439 \u043a\u0430\u043a: \u043a\u043e\u043d\u0442\u0440\u0430\u043a\u0442\u044b, \u0441\u0435\u0440\u0432\u0435\u0440, \u043a\u043b\u0438\u0435\u043d\u0442, auth, \u043b\u043e\u0433\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0435 \u0438 OpenTelemetry. \u0421 \u0434\u0440\u0443\u0433\u043e\u0439 \u0441\u0442\u043e\u0440\u043e\u043d\u044b, \u044d\u0442\u043e \u043f\u043e\u043b\u0435\u0437\u043d\u043e\u0435 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0435, \u043a\u043e\u0442\u043e\u0440\u044b\u043c \u044f \u0441\u0430\u043c \u043f\u043e\u043b\u044c\u0437\u0443\u044e\u0441\u044c \u043a\u0430\u0436\u0434\u044b\u0439 \u0434\u0435\u043d\u044c \u0434\u043b\u044f \u043a\u043e\u043d\u0442\u0440\u043e\u043b\u044f \u0444\u0438\u043d\u0430\u043d\u0441\u043e\u0432. \u0418\u0441\u0445\u043e\u0434\u043d\u044b\u0439 \u043a\u043e\u0434 \u043e\u0442\u043a\u0440\u044b\u0442 \u043d\u0430 GitHub: github.com\/cleverbrush\/xpenser<\/a>.<\/p>\n

\u0414\u0438\u0441\u043a\u043b\u0435\u0439\u043c\u0435\u0440:<\/strong> \u0432\u0441\u0435 \u043e\u043f\u0438\u0441\u044b\u0432\u0430\u0435\u043c\u044b\u0435 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0438 \u043d\u043e\u0441\u044f\u0442 \u044d\u043a\u0441\u043f\u0435\u0440\u0438\u043c\u0435\u043d\u0442\u0430\u043b\u044c\u043d\u044b\u0439 \u0445\u0430\u0440\u0430\u043a\u0442\u0435\u0440. \u041d\u0435\u0441\u043c\u043e\u0442\u0440\u044f \u043d\u0430 \u044d\u0442\u043e, \u043f\u043e\u043a\u0440\u044b\u0442\u0438\u0435 \u0442\u0435\u0441\u0442\u0430\u043c\u0438 \u0443 \u043d\u0438\u0445 \u0434\u043e\u0441\u0442\u0430\u0442\u043e\u0447\u043d\u043e \u0445\u043e\u0440\u043e\u0448\u0435\u0435.<\/p>\n

\u041f\u0440\u0435\u0434\u044b\u0441\u0442\u043e\u0440\u0438\u044f<\/h3>\n

\u0412 \u043f\u0440\u0435\u0434\u044b\u0434\u0443\u0449\u0438\u0445 \u0441\u0442\u0430\u0442\u044c\u044f\u0445 (\u043f\u0435\u0440\u0432\u0430\u044f<\/a> \u0438 \u0432\u0442\u043e\u0440\u0430\u044f<\/a>) \u044f \u0440\u0430\u0441\u0441\u043a\u0430\u0437\u044b\u0432\u0430\u043b \u043e @cleverbrush\/schema<\/code> \u0438 \u043e \u0442\u043e\u043c, \u043a\u0430\u043a \u043d\u0430 \u0435\u0451 \u043e\u0441\u043d\u043e\u0432\u0435 \u043f\u043e\u0441\u0442\u0440\u043e\u0435\u043d\u044b @cleverbrush\/server<\/code> \u0438 @cleverbrush\/client<\/code>. \u0421\u0435\u0433\u043e\u0434\u043d\u044f \u0440\u0435\u0447\u044c \u043f\u043e\u0439\u0434\u0451\u0442 \u043e\u0431 \u0435\u0449\u0451 \u0434\u0432\u0443\u0445 \u044d\u043b\u0435\u043c\u0435\u043d\u0442\u0430\u0445 \u0442\u043e\u0433\u043e \u0436\u0435 \u043c\u043e\u043d\u043e\u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u044f: @cleverbrush\/log<\/code> \u2014 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0430 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u043e\u0433\u043e \u043b\u043e\u0433\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f, \u0438 @cleverbrush\/otel<\/code> \u2014 \u0442\u043e\u043d\u043a\u0430\u044f \u043e\u0431\u0451\u0440\u0442\u043a\u0430 \u043d\u0430\u0434 OpenTelemetry SDK.<\/p>\n

\u041e\u0431\u0430 \u043f\u0430\u043a\u0435\u0442\u0430 \u0438\u0437\u043d\u0430\u0447\u0430\u043b\u044c\u043d\u043e \u043f\u0440\u043e\u0435\u043a\u0442\u0438\u0440\u043e\u0432\u0430\u043b\u0438\u0441\u044c \u043a\u0430\u043a \u0434\u043e\u043f\u043e\u043b\u043d\u0435\u043d\u0438\u0435 \u043a \u0441\u0435\u0440\u0432\u0435\u0440\u0443, \u043d\u043e \u043c\u043e\u0433\u0443\u0442 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c\u0441\u044f \u043d\u0435\u0437\u0430\u0432\u0438\u0441\u0438\u043c\u043e \u2014 \u0432 \u043b\u044e\u0431\u043e\u043c Node.js-\u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0438. \u0412 xpenser \u043e\u043d\u0438 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044e\u0442\u0441\u044f \u0441\u0440\u0430\u0437\u0443 \u0432 \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u0438\u0445 \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u0430\u0445: API, Next.js web app \u0438 Telegram bot.<\/p>\n

@cleverbrush\/log: \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u043e\u0435 \u043b\u043e\u0433\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0435<\/h3>\n

\u0418\u0434\u0435\u044f \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0438 \u043f\u0440\u0438\u0448\u043b\u0430 \u0438\u0437 \u044d\u043a\u043e\u0441\u0438\u0441\u0442\u0435\u043c\u044b .NET: \u0442\u0430\u043c \u0435\u0441\u0442\u044c Serilog \u0441 \u0435\u0433\u043e message templates. \u0418\u0434\u0435\u044f \u0437\u0430\u043a\u043b\u044e\u0447\u0430\u0435\u0442\u0441\u044f \u0432 \u0442\u043e\u043c \u0447\u0442\u043e\u0431\u044b \u0432\u043c\u0435\u0441\u0442\u043e \u0444\u043e\u0440\u043c\u0430\u0442\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f \u0441\u0442\u0440\u043e\u043a\u0438 \u0432 \u043c\u043e\u043c\u0435\u043d\u0442 \u0437\u0430\u043f\u0438\u0441\u0438 \u0432\u044b \u043e\u043f\u0438\u0441\u044b\u0432\u0430\u0435\u0442\u0435 \u0448\u0430\u0431\u043b\u043e\u043d \u0441 \u0438\u043c\u0435\u043d\u043e\u0432\u0430\u043d\u043d\u044b\u043c\u0438 \u043f\u043b\u0435\u0439\u0441\u0445\u043e\u043b\u0434\u0435\u0440\u0430\u043c\u0438, \u0430 \u0432\u0441\u0435 \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u044f \u0445\u0440\u0430\u043d\u044f\u0442\u0441\u044f \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u043e \u043a\u0430\u043a \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u0435 \u0441\u0432\u043e\u0439\u0441\u0442\u0432\u0430. \u042d\u0442\u043e \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0435\u0442 \u0437\u0430\u043f\u0440\u0430\u0448\u0438\u0432\u0430\u0442\u044c \u043b\u043e\u0433\u0438 \u0432 \u0431\u0430\u0437\u0435 \u0434\u0430\u043d\u043d\u044b\u0445 \u043f\u043e \u043a\u043e\u043d\u043a\u0440\u0435\u0442\u043d\u044b\u043c \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u044f\u043c \u2014 \u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u043d\u0430\u0439\u0442\u0438 \u0432\u0441\u0435 \u0441\u043e\u0431\u044b\u0442\u0438\u044f \u043f\u043e TransactionId<\/code> \u0438\u043b\u0438 UserId<\/code>.<\/p>\n

\u041d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u0441\u043e\u0431\u044b\u0442\u0438\u0435 \u0441\u043e\u0437\u0434\u0430\u043d\u0438\u044f \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u0438 \u0432 xpenser \u0443\u0434\u043e\u0431\u043d\u043e \u043e\u043f\u0438\u0441\u0430\u0442\u044c \u0442\u0438\u043f\u0438\u0437\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u043c \u0441\u0442\u0440\u043e\u043a\u043e\u0432\u044b\u043c \u0448\u0430\u0431\u043b\u043e\u043d\u043e\u043c:<\/p>\n

import { number, object, parseString } from '@cleverbrush\/schema';const TransactionCreated = parseString(    object({ TransactionId: number(), UserId: number() }),    $t =>        $t`Transaction ${t => t.TransactionId} created by ${t => t.UserId}`);logger.info(TransactionCreated, {    TransactionId: transaction.id,    UserId: principal.userId});<\/code>
<\/a><\/div><\/pre>\n
\u0421\u0432\u043e\u0439\u0441\u0442\u0432\u0430 {TransactionId}<\/code> \u0438 {UserId}<\/code> \u0441\u043e\u0445\u0440\u0430\u043d\u044f\u044e\u0442\u0441\u044f \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u043e \u043e\u0442 \u0442\u0435\u043a\u0441\u0442\u0430 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f, \u0430 \u0441\u0430\u043c \u0448\u0430\u0431\u043b\u043e\u043d \u043e\u0441\u0442\u0430\u0451\u0442\u0441\u044f \u0441\u0442\u0430\u0431\u0438\u043b\u044c\u043d\u044b\u043c: Transaction {TransactionId} created by {UserId}<\/code>. \u0412 SigNoz, Clickstack \u0438\u043b\u0438 \u043b\u044e\u0431\u043e\u0439 \u0434\u0440\u0443\u0433\u043e\u0439 \u0441\u0438\u0441\u0442\u0435\u043c\u0435, \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u0438\u0432\u0430\u044e\u0449\u0435\u0439 CLEF-\u0444\u043e\u0440\u043c\u0430\u0442, \u044d\u0442\u0438 \u043f\u043e\u043b\u044f \u043c\u043e\u0436\u043d\u043e \u0444\u0438\u043b\u044c\u0442\u0440\u043e\u0432\u0430\u0442\u044c \u0438 \u0430\u0433\u0440\u0435\u0433\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u043a\u0430\u043a \u043d\u043e\u0440\u043c\u0430\u043b\u044c\u043d\u044b\u0435 \u043a\u043e\u043b\u043e\u043d\u043a\u0438.<\/p>\n
\u0414\u043e\u0441\u0442\u0443\u043f\u043d\u044b\u0435 \u0443\u0440\u043e\u0432\u043d\u0438: trace, debug, info, warn, error, fatal. \u041c\u0435\u0442\u043e\u0434\u044b logger.error()<\/code> \u043f\u0440\u0438\u043d\u0438\u043c\u0430\u044e\u0442 \u043e\u043f\u0446\u0438\u043e\u043d\u0430\u043b\u044c\u043d\u044b\u0439 \u043e\u0431\u044a\u0435\u043a\u0442 Error<\/code> \u043f\u0435\u0440\u0432\u044b\u043c \u0430\u0440\u0433\u0443\u043c\u0435\u043d\u0442\u043e\u043c. \u041d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a MCP transport \u0432 xpenser \u043f\u0438\u0448\u0435\u0442 \u043e\u0448\u0438\u0431\u043a\u0443 \u0432\u043c\u0435\u0441\u0442\u0435 \u0441 \u0438\u0434\u0435\u043d\u0442\u0438\u0444\u0438\u043a\u0430\u0442\u043e\u0440\u043e\u043c \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044f:<\/p>\n
transport. => {    logger.error(error, McpTransportError, {        UserId: apiKeyPrincipal.userId    });};<\/code>
<\/a><\/div><\/pre>\n
\"\u0421\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u0435<\/p>\n
\u0421\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u0435 \u043b\u043e\u0433\u0438 \u0432 SigNoz: \u0441\u0432\u043e\u0439\u0441\u0442\u0432\u0430 TransactionId, UserId \u0434\u043e\u0441\u0442\u0443\u043f\u043d\u044b \u043a\u0430\u043a \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u044b\u0435 \u043a\u043e\u043b\u043e\u043d\u043a\u0438<\/figcaption><\/div>\n<\/figure>\n
Sinks: \u043a\u0443\u0434\u0430 \u043f\u0438\u0441\u0430\u0442\u044c \u043b\u043e\u0433\u0438<\/h4>\n
Sink \u2014 \u044d\u0442\u043e \u043f\u0440\u0438\u0451\u043c\u043d\u0438\u043a \u043b\u043e\u0433-\u0441\u043e\u0431\u044b\u0442\u0438\u0439. \u041c\u043e\u0436\u043d\u043e \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0438\u0442\u044c \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u043e\u0434\u043d\u043e\u0432\u0440\u0435\u043c\u0435\u043d\u043d\u043e. \u0412 xpenser API \u043e\u0434\u0438\u043d \u0438 \u0442\u043e\u0442 \u0436\u0435 logger \u043f\u0438\u0448\u0435\u0442 \u0432 \u043a\u043e\u043d\u0441\u043e\u043b\u044c \u0438 \u0432 OpenTelemetry Logs:<\/p>\n
import {    consoleSink,    createLogger,    hostnameEnricher,    processIdEnricher} from '@cleverbrush\/log';import { otelLogSink, traceEnricher } from '@cleverbrush\/otel';const logger = createLogger({    minimumLevel: config.logLevel,    sinks: [consoleSink({ theme: 'dark' }), otelLogSink()],    enrichers: [hostnameEnricher(), processIdEnricher(), traceEnricher()],    handleProcessExit: true});<\/code>
<\/a><\/div><\/pre>\n
consoleSink<\/code> \u0432\u044b\u0432\u043e\u0434\u0438\u0442 \u0441\u043e\u0431\u044b\u0442\u0438\u044f \u0432 stdout\/stderr \u0441 \u0446\u0432\u0435\u0442\u043e\u0432\u044b\u043c \u0432\u044b\u0434\u0435\u043b\u0435\u043d\u0438\u0435\u043c \u0443\u0440\u043e\u0432\u043d\u0435\u0439. otelLogSink()<\/code> \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u0442 \u0442\u0435 \u0436\u0435 \u0441\u043e\u0431\u044b\u0442\u0438\u044f \u043a\u0430\u043a OTel Log Records \u0432 OTLP-\u043a\u043e\u043b\u043b\u0435\u043a\u0442\u043e\u0440. \u0412 \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u0435 \u043b\u043e\u0433\u0438, \u0442\u0440\u0435\u0439\u0441\u044b \u0438 \u043c\u0435\u0442\u0440\u0438\u043a\u0438 \u043f\u043e\u043f\u0430\u0434\u0430\u044e\u0442 \u0432 \u043e\u0434\u043d\u0443 observability-\u0438\u043d\u0444\u0440\u0430\u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0443 \u0438 \u043c\u043e\u0433\u0443\u0442 \u0431\u044b\u0442\u044c \u0441\u0432\u044f\u0437\u0430\u043d\u044b \u043c\u0435\u0436\u0434\u0443 \u0441\u043e\u0431\u043e\u0439.<\/p>\n
\u0414\u043b\u044f \u043b\u043e\u043a\u0430\u043b\u044c\u043d\u043e\u0433\u043e \u0444\u0430\u0439\u043b\u0430 \u0438\u043b\u0438 \u0431\u0430\u0442\u0447\u0438\u043d\u0433\u0430 \u043c\u043e\u0436\u043d\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c fileSink<\/code> \u0438 BatchingSink<\/code>, \u043d\u043e \u0432 xpenser \u043e\u0441\u043d\u043e\u0432\u043d\u043e\u0439 \u043f\u0440\u043e\u0434\u0430\u043a\u0448\u0435\u043d-\u0441\u0446\u0435\u043d\u0430\u0440\u0438\u0439 \u2014 console + OTLP, \u043f\u043e\u0442\u043e\u043c\u0443 \u0447\u0442\u043e \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0435 \u0437\u0430\u043f\u0443\u0441\u043a\u0430\u0435\u0442\u0441\u044f \u0432 \u043a\u043e\u043d\u0442\u0435\u0439\u043d\u0435\u0440\u0430\u0445.<\/p>\n
Enrichers: \u0430\u0432\u0442\u043e\u043c\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u0434\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u043c\u044b\u0435 \u0441\u0432\u043e\u0439\u0441\u0442\u0432\u0430<\/h4>\n
Enricher \u2014 \u0444\u0443\u043d\u043a\u0446\u0438\u044f, \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u0434\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u0442 \u043e\u0434\u0438\u043d\u0430\u043a\u043e\u0432\u044b\u0435 \u0441\u0432\u043e\u0439\u0441\u0442\u0432\u0430 \u043a\u043e \u0432\u0441\u0435\u043c \u043b\u043e\u0433-\u0441\u043e\u0431\u044b\u0442\u0438\u044f\u043c. \u0412\u043c\u0435\u0441\u0442\u043e \u0442\u043e\u0433\u043e \u0447\u0442\u043e\u0431\u044b \u0432 \u043a\u0430\u0436\u0434\u043e\u043c \u0432\u044b\u0437\u043e\u0432\u0435 logger.info<\/code><\/a>(...)<\/code> \u043f\u0435\u0440\u0435\u0434\u0430\u0432\u0430\u0442\u044c PID, \u0438\u043c\u044f \u0445\u043e\u0441\u0442\u0430 \u0438\u043b\u0438 trace id, \u0438\u0445 \u0434\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u0442 enricher.<\/p>\n
\u0412 API xpenser \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u044b hostname, process id \u0438 trace\/span correlation:<\/p>\n
const logger = createLogger({    minimumLevel: config.logLevel,    sinks: [consoleSink({ theme: 'dark' }), otelLogSink()],    enrichers: [hostnameEnricher(), processIdEnricher(), traceEnricher()]});<\/code>
<\/a><\/div><\/pre>\n
traceEnricher()<\/code> \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u043d\u043e \u0441 \u0430\u043a\u0442\u0438\u0432\u043d\u044b\u043c OpenTelemetry-\u043a\u043e\u043d\u0442\u0435\u043a\u0441\u0442\u043e\u043c: \u0435\u0441\u043b\u0438 \u043b\u043e\u0433 \u0437\u0430\u043f\u0438\u0441\u0430\u043d \u0432\u043d\u0443\u0442\u0440\u0438 HTTP-\u0437\u0430\u043f\u0440\u043e\u0441\u0430, \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u043e\u0433\u043e \u0437\u0430\u043f\u0440\u043e\u0441\u0430 \u0438\u043b\u0438 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044c\u0441\u043a\u043e\u0433\u043e \u0441\u043f\u0430\u043d\u0430, \u0441\u043e\u0431\u044b\u0442\u0438\u0435 \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u0442 TraceId<\/code> \u0438 SpanId<\/code>.<\/p>\n
\u0414\u043b\u044f HTTP correlation id \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f useLogging()<\/code> \u0438\u0437 @cleverbrush\/log<\/code>. \u0412 xpenser API middleware \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0430\u0435\u0442\u0441\u044f \u043a @cleverbrush\/server<\/code> \u0442\u0430\u043a:<\/p>\n
const [correlationMiddleware, requestLogMiddleware] = useLogging(logger, {    excludePaths: ['\/health'],    correlationResponseHeader: false});<\/code>
<\/a><\/div><\/pre>\n
CorrelationId \u043f\u043e\u043b\u0435\u0437\u0435\u043d \u0432 \u0440\u0430\u0441\u043f\u0440\u0435\u0434\u0435\u043b\u0451\u043d\u043d\u044b\u0445 \u0441\u0438\u0441\u0442\u0435\u043c\u0430\u0445, \u0433\u0434\u0435 \u043e\u0434\u0438\u043d \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044c\u0441\u043a\u0438\u0439 \u0437\u0430\u043f\u0440\u043e\u0441 \u043f\u0440\u043e\u0445\u043e\u0434\u0438\u0442 \u0447\u0435\u0440\u0435\u0437 \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u0441\u0435\u0440\u0432\u0438\u0441\u043e\u0432. \u041e\u0434\u0438\u043d \u0438 \u0442\u043e\u0442 \u0436\u0435 \u0438\u0434\u0435\u043d\u0442\u0438\u0444\u0438\u043a\u0430\u0442\u043e\u0440, \u043f\u0435\u0440\u0435\u0434\u0430\u043d\u043d\u044b\u0439 \u0447\u0435\u0440\u0435\u0437 HTTP-\u0437\u0430\u0433\u043e\u043b\u043e\u0432\u043e\u043a, \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0435\u0442 \u0441\u043e\u0431\u0440\u0430\u0442\u044c \u0432\u0441\u0435 \u043b\u043e\u0433\u0438 \u044d\u0442\u043e\u0433\u043e \u0437\u0430\u043f\u0440\u043e\u0441\u0430 \u2014 \u043e\u0442 web app \u0434\u043e API \u0438 \u0431\u0430\u0437\u044b \u0434\u0430\u043d\u043d\u044b\u0445 \u2014 \u043f\u043e \u043e\u0434\u043d\u043e\u043c\u0443 \u043f\u043e\u043b\u044e.<\/p>\n
\u041a\u043e\u043d\u0442\u0435\u043a\u0441\u0442\u043d\u044b\u0435 \u043b\u043e\u0433\u0433\u0435\u0440\u044b<\/h4>\n
\u041c\u0435\u0442\u043e\u0434 forContext()<\/code> \u0441\u043e\u0437\u0434\u0430\u0451\u0442 \u0434\u043e\u0447\u0435\u0440\u043d\u0438\u0439 \u043b\u043e\u0433\u0433\u0435\u0440 \u0441 \u0434\u043e\u043f\u043e\u043b\u043d\u0438\u0442\u0435\u043b\u044c\u043d\u044b\u043c\u0438 \u0441\u0432\u043e\u0439\u0441\u0442\u0432\u0430\u043c\u0438, \u043d\u0435 \u043c\u0435\u043d\u044f\u044f \u043e\u0440\u0438\u0433\u0438\u043d\u0430\u043b. \u0412 Next.js \u0447\u0430\u0441\u0442\u0438 xpenser \u0435\u0441\u0442\u044c helper loggerFor()<\/code>:<\/p>\n
export function loggerFor(sourceContext: string): Logger {    return logger.forContext('SourceContext', sourceContext);}<\/code>
<\/a><\/div><\/pre>\n
Auth.js \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442 \u0435\u0433\u043e, \u0447\u0442\u043e\u0431\u044b \u043e\u0442\u0434\u0435\u043b\u0438\u0442\u044c auth-\u0441\u043e\u0431\u044b\u0442\u0438\u044f \u043e\u0442 \u043e\u0441\u0442\u0430\u043b\u044c\u043d\u044b\u0445 \u043b\u043e\u0433\u043e\u0432:<\/p>\n
const authLogger = loggerFor('Auth.js');authLogger.error(error, AuthErrorLogged, {    AuthErrorType: authErrorType(error),    AuthErrorMessage: error.message});<\/code>
<\/a><\/div><\/pre>\n
\u0412\u0441\u0435 \u0441\u043e\u0431\u044b\u0442\u0438\u044f \u0442\u0430\u043a\u043e\u0433\u043e \u043b\u043e\u0433\u0433\u0435\u0440\u0430 \u0431\u0443\u0434\u0443\u0442 \u0441\u043e\u0434\u0435\u0440\u0436\u0430\u0442\u044c SourceContext: 'Auth.js'<\/code>. \u042d\u0442\u043e \u0443\u0434\u043e\u0431\u043d\u043e \u0434\u043b\u044f \u0444\u0438\u043b\u044c\u0442\u0440\u0430\u0446\u0438\u0438 \u043b\u043e\u0433\u043e\u0432 \u043f\u043e \u043a\u043e\u043c\u043f\u043e\u043d\u0435\u043d\u0442\u0430\u043c \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f: API handlers, Auth.js, MCP server, Telegram bot.<\/p>\n
\u0422\u0438\u043f\u0438\u0437\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u0435 \u0448\u0430\u0431\u043b\u043e\u043d\u044b \u0447\u0435\u0440\u0435\u0437 @cleverbrush\/schema<\/h4>\n
\u041e\u0434\u043d\u0430 \u0438\u0437 \u0441\u0430\u043c\u044b\u0445 \u0438\u043d\u0442\u0435\u0440\u0435\u0441\u043d\u044b\u0445 \u043e\u0441\u043e\u0431\u0435\u043d\u043d\u043e\u0441\u0442\u0435\u0439: message templates \u043c\u043e\u0436\u043d\u043e \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u0442\u0438\u043f\u0438\u0437\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u043c\u0438, \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044f parseString()<\/code> \u0438\u0437 @cleverbrush\/schema<\/code>. \u042d\u0442\u043e \u0434\u0430\u0451\u0442 \u043f\u043e\u043b\u043d\u0443\u044e \u043f\u0440\u043e\u0432\u0435\u0440\u043a\u0443 \u0442\u0438\u043f\u043e\u0432 \u0432 \u043c\u043e\u043c\u0435\u043d\u0442 \u0432\u044b\u0437\u043e\u0432\u0430 logger.info<\/code><\/a>()<\/code>.<\/p>\n
\u0412 xpenser \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u0435 \u0441\u043e\u0431\u044b\u0442\u0438\u044f \u0432\u044b\u043d\u0435\u0441\u0435\u043d\u044b \u0432 \u043d\u0435\u0431\u043e\u043b\u044c\u0448\u0438\u0435 \u043c\u043e\u0434\u0443\u043b\u0438 \u0441 log templates \u0438 \u0442\u0438\u043f\u0438\u0437\u0438\u0440\u043e\u0432\u0430\u043d\u044b \u0442\u043e\u0439 \u0436\u0435 \u0441\u0445\u0435\u043c\u043d\u043e\u0439 \u0441\u0438\u0441\u0442\u0435\u043c\u043e\u0439, \u043d\u0430 \u043a\u043e\u0442\u043e\u0440\u043e\u0439 \u043f\u043e\u0441\u0442\u0440\u043e\u0435\u043d\u044b API-\u043a\u043e\u043d\u0442\u0440\u0430\u043a\u0442\u044b:<\/p>\n
import { number, object, parseString } from '@cleverbrush\/schema';const TransactionCreated = parseString(    object({ TransactionId: number(), UserId: number() }),    $t =>        $t`Transaction ${t => t.TransactionId} created by ${t => t.UserId}`);logger.info(TransactionCreated, {    TransactionId: transaction.id,    UserId: principal.userId});<\/code>
<\/a><\/div><\/pre>\n
\u0415\u0441\u043b\u0438 \u043f\u0440\u043e\u043f\u0443\u0441\u0442\u0438\u0442\u044c \u043f\u043e\u043b\u0435 \u0438\u043b\u0438 \u043f\u0435\u0440\u0435\u0434\u0430\u0442\u044c \u043d\u0435\u043f\u0440\u0430\u0432\u0438\u043b\u044c\u043d\u044b\u0439 \u0442\u0438\u043f, TypeScript \u043f\u043e\u043a\u0430\u0436\u0435\u0442 \u043e\u0448\u0438\u0431\u043a\u0443 \u0435\u0449\u0451 \u0434\u043e \u0437\u0430\u043f\u0443\u0441\u043a\u0430 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f. \u0422\u0430\u043a\u043e\u0439 \u043f\u043e\u0434\u0445\u043e\u0434 \u043e\u0441\u043e\u0431\u0435\u043d\u043d\u043e \u0443\u0434\u043e\u0431\u0435\u043d \u0434\u043b\u044f \u0441\u043e\u0431\u044b\u0442\u0438\u0439, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043f\u043e\u0442\u043e\u043c \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044e\u0442\u0441\u044f \u0432 \u0430\u043b\u0435\u0440\u0442\u0430\u0445, \u0434\u0430\u0448\u0431\u043e\u0440\u0434\u0430\u0445 \u0438\u043b\u0438 \u043f\u043e\u0438\u0441\u043a\u0435 \u0438\u043d\u0446\u0438\u0434\u0435\u043d\u0442\u043e\u0432.<\/p>\n
\u0418\u043d\u0442\u0435\u0433\u0440\u0430\u0446\u0438\u044f \u0441 @cleverbrush\/server<\/h4>\n
\u0414\u043b\u044f \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u044f \u043b\u043e\u0433\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f \u043a \u0441\u0435\u0440\u0432\u0435\u0440\u0443 \u0434\u043e\u0441\u0442\u0430\u0442\u043e\u0447\u043d\u043e \u043e\u0434\u043d\u043e\u0439 \u0444\u0443\u043d\u043a\u0446\u0438\u0438. \u0412 xpenser API \u044d\u0442\u043e \u0432\u044b\u0433\u043b\u044f\u0434\u0438\u0442 \u0442\u0430\u043a:<\/p>\n
import type { Logger } from '@cleverbrush\/log';import { useLogging } from '@cleverbrush\/log';import { tracingMiddleware } from '@cleverbrush\/otel';import { createServer } from '@cleverbrush\/server';export function buildServer(    config: Config,    logger: Logger,    resources: DbResources) {    const [correlationMiddleware, requestLogMiddleware] = useLogging(logger, {        excludePaths: ['\/health'],        correlationResponseHeader: false    });    return createServer({ maxBodySize: 1024 * 1024 })        .use(tracingMiddleware({ excludePaths: ['\/health'] }))        .use(corsMiddleware(config))        .use(correlationMiddleware)        .use(requestLogMiddleware)        .services(services => configureDI(services, config, logger, resources));}<\/code>
<\/a><\/div><\/pre>\n
useLogging()<\/code> \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u0442 \u0434\u0432\u0430 middleware: \u043f\u0435\u0440\u0432\u044b\u0439 \u0443\u0441\u0442\u0430\u043d\u0430\u0432\u043b\u0438\u0432\u0430\u0435\u0442 correlation context \u0434\u043b\u044f \u0437\u0430\u043f\u0440\u043e\u0441\u0430, \u0432\u0442\u043e\u0440\u043e\u0439 \u043b\u043e\u0433\u0438\u0440\u0443\u0435\u0442 \u0437\u0430\u0432\u0435\u0440\u0448\u0435\u043d\u0438\u0435 \u043a\u0430\u0436\u0434\u043e\u0433\u043e HTTP-\u0437\u0430\u043f\u0440\u043e\u0441\u0430 \u0441 \u043c\u0435\u0442\u043e\u0434\u043e\u043c, \u043f\u0443\u0442\u0451\u043c, \u0441\u0442\u0430\u0442\u0443\u0441-\u043a\u043e\u0434\u043e\u043c \u0438 \u0432\u0440\u0435\u043c\u0435\u043d\u0435\u043c \u0432\u044b\u043f\u043e\u043b\u043d\u0435\u043d\u0438\u044f.<\/p>\n
\u0417\u0430\u043f\u0438\u0441\u044c \u0432 \u043b\u043e\u0433 \u0432\u043d\u0443\u0442\u0440\u0438 handler \u2014 \u0447\u0435\u0440\u0435\u0437 \u0438\u043d\u044a\u0435\u043a\u0446\u0438\u044e \u043b\u043e\u0433\u0433\u0435\u0440\u0430:<\/p>\n
export const createTransactionHandler: Handler<    typeof CreateTransactionEndpoint> = async ({ body, principal }, { db, config, logger }) => {    const transaction = await createTransaction(        db,        config,        principal.userId,        body    );    logger.info(TransactionCreated, {        TransactionId: transaction.id,        UserId: principal.userId    });    return ActionResult.created(        transaction,        `\/api\/transactions\/${transaction.id}`    );};<\/code>
<\/a><\/div><\/pre>\n
@cleverbrush\/otel: OpenTelemetry \u0431\u0435\u0437 \u0431\u043e\u0439\u043b\u0435\u0440\u043f\u043b\u0435\u0439\u0442\u0430<\/h3>\n
\u041f\u0430\u043a\u0435\u0442 @cleverbrush\/otel<\/code> \u0440\u0435\u0448\u0430\u0435\u0442 \u0434\u0432\u0435 \u0437\u0430\u0434\u0430\u0447\u0438: \u0437\u0430\u043f\u0443\u0441\u0442\u0438\u0442\u044c OpenTelemetry SDK \u043e\u0434\u043d\u043e\u0439 \u0444\u0443\u043d\u043a\u0446\u0438\u0435\u0439 \u0438 \u043f\u0440\u0435\u0434\u043e\u0441\u0442\u0430\u0432\u0438\u0442\u044c \u0443\u0434\u043e\u0431\u043d\u044b\u0435 \u0438\u043d\u0442\u0435\u0433\u0440\u0430\u0446\u0438\u0438 \u0434\u043b\u044f \u0441\u0435\u0440\u0432\u0435\u0440\u043d\u043e\u0433\u043e \u0438 \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u043e\u0433\u043e \u043a\u043e\u0434\u0430 Cleverbrush.<\/p>\n
\u0418\u043d\u0438\u0446\u0438\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044f SDK<\/h4>\n
setupOtel()<\/code> \u0437\u0430\u043f\u0443\u0441\u043a\u0430\u0435\u0442 NodeSDK \u0441 OTLP\/HTTP-\u044d\u043a\u0441\u043f\u043e\u0440\u0442\u0451\u0440\u0430\u043c\u0438 \u0434\u043b\u044f \u0442\u0440\u0435\u0439\u0441\u043e\u0432, \u043c\u0435\u0442\u0440\u0438\u043a \u0438 \u043b\u043e\u0433\u043e\u0432. \u0412 xpenser API \u044d\u0442\u043e \u0432\u044b\u043d\u0435\u0441\u0435\u043d\u043e \u0432 telemetry.ts<\/code>:<\/p>\n
import { setupOtel } from '@cleverbrush\/otel';import { HttpInstrumentation } from '@opentelemetry\/instrumentation-http';import { RuntimeNodeInstrumentation } from '@opentelemetry\/instrumentation-runtime-node';import { UndiciInstrumentation } from '@opentelemetry\/instrumentation-undici';const endpoint =    process.env.OTEL_EXPORTER_OTLP_ENDPOINT ?? 'http:\/\/otel-collector:4318';export const otel = setupOtel({    serviceName: process.env.OTEL_SERVICE_NAME ?? 'xpenser-api',    serviceVersion: process.env.npm_package_version,    environment: process.env.NODE_ENV,    otlpEndpoint: endpoint,    instrumentations: [        new HttpInstrumentation({            ignoreIncomingRequestHook: request => isHealthPath(request.url)        }),        new UndiciInstrumentation(),        new RuntimeNodeInstrumentation()    ]});<\/code>
<\/a><\/div><\/pre>\n
\u042d\u0442\u043e\u0442 \u043c\u043e\u0434\u0443\u043b\u044c \u0434\u043e\u043b\u0436\u0435\u043d \u0431\u044b\u0442\u044c \u0438\u043c\u043f\u043e\u0440\u0442\u0438\u0440\u043e\u0432\u0430\u043d \u0434\u043e \u043a\u043e\u0434\u0430, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043d\u0443\u0436\u043d\u043e \u0430\u0432\u0442\u043e\u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442\u0438\u0440\u043e\u0432\u0430\u0442\u044c. \u0412 xpenser API entrypoint \u0438\u043c\u043f\u043e\u0440\u0442\u0438\u0440\u0443\u0435\u0442 otel<\/code> \u0438\u0437 .\/telemetry.js<\/code>, \u0430 \u043f\u0440\u0438 shutdown \u043a\u043e\u0440\u0440\u0435\u043a\u0442\u043d\u043e \u0432\u044b\u0437\u044b\u0432\u0430\u0435\u0442 otel.shutdown()<\/code>.<\/p>\n
\u0412 Next.js \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0438 xpenser \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u043f\u043e\u0445\u043e\u0436\u0430\u044f \u0441\u0445\u0435\u043c\u0430, \u043d\u043e \u0441 \u0434\u0440\u0443\u0433\u0438\u043c \u0438\u043c\u0435\u043d\u0435\u043c \u0441\u0435\u0440\u0432\u0438\u0441\u0430:<\/p>\n
export const otel =    existingOtel ??    setupOtel({        serviceName: process.env.WEB_OTEL_SERVICE_NAME ?? 'xpenser-web',        serviceVersion: process.env.npm_package_version,        environment: process.env.NODE_ENV,        otlpEndpoint: endpoint    });<\/code>
<\/a><\/div><\/pre>\n
\u0412 \u0438\u0442\u043e\u0433\u0435 \u0432 SigNoz \u0432\u0438\u0434\u043d\u043e \u0434\u0432\u0430 \u0441\u0435\u0440\u0432\u0438\u0441\u0430: xpenser-web<\/code> \u0438 xpenser-api<\/code>.<\/p>\n
\u041f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044c\u0441\u043a\u0438\u0435 \u0441\u043f\u0430\u043d\u044b<\/h4>\n
\u0410\u0432\u0442\u043e\u043c\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u043e\u0435 \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0435 \u043f\u043e\u043a\u0440\u044b\u0432\u0430\u0435\u0442 HTTP \u0438 SQL \u0432\u044b\u0437\u043e\u0432\u044b, \u043d\u043e \u0431\u0438\u0437\u043d\u0435\u0441-\u043b\u043e\u0433\u0438\u043a\u0430 \u0438\u043d\u043e\u0433\u0434\u0430 \u0442\u0440\u0435\u0431\u0443\u0435\u0442 \u0441\u0432\u043e\u0438\u0445 \u0441\u043f\u0430\u043d\u043e\u0432. \u0412 xpenser \u0442\u0430\u043a\u043e\u0439 \u043f\u0440\u0438\u043c\u0435\u0440 \u0435\u0441\u0442\u044c \u0432 Telegram bot: \u0432\u0445\u043e\u0434\u044f\u0449\u0438\u0435 Telegram updates \u043d\u0435 \u044f\u0432\u043b\u044f\u044e\u0442\u0441\u044f \u043e\u0431\u044b\u0447\u043d\u044b\u043c\u0438 HTTP-\u0437\u0430\u043f\u0440\u043e\u0441\u0430\u043c\u0438 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f, \u043f\u043e\u044d\u0442\u043e\u043c\u0443 \u0434\u043b\u044f \u043d\u0438\u0445 \u0441\u043e\u0437\u0434\u0430\u0451\u0442\u0441\u044f consumer span \u0432\u0440\u0443\u0447\u043d\u0443\u044e.<\/p>\n
const tracer = trace.getTracer('xpenser.telegram-bot');export async function traceTelegramUpdate<T>(    info: TelegramUpdateSpanInfo,    handler: () => Promise<T>): Promise<T> {    return tracer.startActiveSpan(        telegramSpanName(info),        {            kind: SpanKind.CONSUMER,            attributes: telegramSpanAttributes(info)        },        async span => {            try {                const result = await handler();                span.setAttribute('telegram.update.success', true);                span.setStatus({ code: SpanStatusCode.OK });                return result;            } catch (err) {                span.setAttribute('telegram.update.success', false);                span.recordException(                    err instanceof Error ? err : errorMessage(err)                );                span.setStatus({                    code: SpanStatusCode.ERROR,                    message: errorMessage(err)                });                throw err;            } finally {                span.end();            }        }    );}<\/code>
<\/a><\/div><\/pre>\n
\u0422\u0430\u043a\u043e\u0439 span \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u0442 \u0430\u0442\u0440\u0438\u0431\u0443\u0442\u044b \u0432\u0440\u043e\u0434\u0435 messaging.system<\/code>, telegram.update.type<\/code>, telegram.command<\/code> \u0438\u043b\u0438 telegram.callback.action<\/code>. \u0415\u0441\u043b\u0438 \u043a\u043e\u043c\u0430\u043d\u0434\u0430 \u043f\u0430\u0434\u0430\u0435\u0442, \u0438\u0441\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0435 \u043f\u043e\u043f\u0430\u0434\u0430\u0435\u0442 \u0432 trace, \u0430 \u0441\u0442\u0430\u0442\u0443\u0441 \u0441\u043f\u0430\u043d\u0430 \u0441\u0442\u0430\u043d\u043e\u0432\u0438\u0442\u0441\u044f ERROR<\/code>.<\/p>\n
\u0422\u0440\u0435\u0439\u0441\u0438\u043d\u0433 HTTP-\u0437\u0430\u043f\u0440\u043e\u0441\u043e\u0432<\/h4>\n
tracingMiddleware()<\/code> \u0438\u0437 @cleverbrush\/otel<\/code> \u0430\u0432\u0442\u043e\u043c\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u0441\u043e\u0437\u0434\u0430\u0451\u0442 \u0441\u043f\u0430\u043d \u0434\u043b\u044f \u043a\u0430\u0436\u0434\u043e\u0433\u043e HTTP-\u0437\u0430\u043f\u0440\u043e\u0441\u0430 \u043a @cleverbrush\/server<\/code>. \u0421\u043f\u0430\u043d \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u0442 \u0441\u0442\u0430\u043d\u0434\u0430\u0440\u0442\u043d\u044b\u0435 OTel HTTP-\u0430\u0442\u0440\u0438\u0431\u0443\u0442\u044b: \u043c\u0435\u0442\u043e\u0434, \u043f\u0443\u0442\u044c, \u0441\u0442\u0430\u0442\u0443\u0441-\u043a\u043e\u0434, user-agent.<\/p>\n
\u0412 xpenser middleware \u0441\u0442\u043e\u0438\u0442 \u043f\u0435\u0440\u0432\u044b\u043c \u0432 \u0441\u0435\u0440\u0432\u0435\u0440\u043d\u043e\u0439 \u0446\u0435\u043f\u043e\u0447\u043a\u0435:<\/p>\n
const server = createServer({ maxBodySize: 1024 * 1024 })    .use(tracingMiddleware({ excludePaths: ['\/health'] }))    .use(corsMiddleware(config))    .use(correlationMiddleware)    .use(requestLogMiddleware);<\/code>
<\/a><\/div><\/pre>\n
\u0412\u0430\u0436\u043d\u043e, \u0447\u0442\u043e CORS \u0440\u0430\u0437\u0440\u0435\u0448\u0430\u0435\u0442 propagation-\u0437\u0430\u0433\u043e\u043b\u043e\u0432\u043a\u0438:<\/p>\n
ctx.response.setHeader(    'Access-Control-Allow-Headers',    'Content-Type, Authorization, X-API-Key, Mcp-Protocol-Version, Mcp-Session-Id, traceparent, tracestate, baggage');<\/code>
<\/a><\/div><\/pre>\n
\u0411\u043b\u0430\u0433\u043e\u0434\u0430\u0440\u044f traceparent<\/code>, tracestate<\/code> \u0438 baggage<\/code> trace context \u043c\u043e\u0436\u0435\u0442 \u043f\u0440\u043e\u0439\u0442\u0438 \u043e\u0442 web app \u043a API.<\/p>\n
\u0422\u0440\u0435\u0439\u0441\u0438\u043d\u0433 \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u0438\u0445 \u0437\u0430\u043f\u0440\u043e\u0441\u043e\u0432<\/h4>\n
xpenser \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442 @cleverbrush\/client<\/code>, \u0441\u0433\u0435\u043d\u0435\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u0439 \u0438\u0437 \u043e\u0431\u0449\u0435\u0433\u043e API-\u043a\u043e\u043d\u0442\u0440\u0430\u043a\u0442\u0430. \u0427\u0442\u043e\u0431\u044b \u0437\u0430\u043f\u0440\u043e\u0441\u044b \u043a\u043b\u0438\u0435\u043d\u0442\u0430 \u043f\u043e\u043f\u0430\u0434\u0430\u043b\u0438 \u0432 \u0442\u043e\u0442 \u0436\u0435 distributed trace, \u0432 \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u0443\u044e \u0446\u0435\u043f\u043e\u0447\u043a\u0443 \u0434\u043e\u0431\u0430\u0432\u043b\u0435\u043d clientTracingMiddleware()<\/code>:<\/p>\n
import { createClient } from '@cleverbrush\/client';import { clientTracingMiddleware } from '@cleverbrush\/otel\/client';import { api } from '@xpenser\/contracts';export function createXpenserClient(options: XpenserClientOptions) {    return createClient(api, {        baseUrl: options.baseUrl,        getToken: options.getToken,        headers: options.headers,        onUnauthorized: options.onUnauthorized,        fetch: options.fetch,        middlewares: [            clientTracingMiddleware(),            retry({ limit: 2, retryOnTimeout: true }),            timeout({ timeout: 10_000 }),            dedupe(),            cacheTags({                defaultTtl: 5_000,                ttlByTag: {                    currencies: 24 * 60 * 60 * 1_000,                    dashboard: 60_000,                    transactions: 30_000,                    categories: 30_000,                    'user-profile': 30_000                }            })        ]    });}<\/code>
<\/a><\/div><\/pre>\n
\u0415\u0441\u043b\u0438 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044c \u043e\u0442\u043a\u0440\u044b\u0432\u0430\u0435\u0442 dashboard, Next.js server code \u0432\u044b\u0437\u044b\u0432\u0430\u0435\u0442 API \u0447\u0435\u0440\u0435\u0437 typed client, \u0430 SigNoz \u043f\u043e\u043a\u0430\u0437\u044b\u0432\u0430\u0435\u0442 \u0441\u0432\u044f\u0437\u043a\u0443 xpenser-web -> xpenser-api -> PostgreSQL<\/code> \u0432 \u043e\u0434\u043d\u043e\u043c trace.<\/p>\n
\u0422\u0440\u0435\u0439\u0441\u0438\u043d\u0433 SQL-\u0437\u0430\u043f\u0440\u043e\u0441\u043e\u0432<\/h4>\n
instrumentKnex()<\/code> \u043e\u0431\u043e\u0440\u0430\u0447\u0438\u0432\u0430\u0435\u0442 Knex-\u0438\u043d\u0441\u0442\u0430\u043d\u0441 \u0442\u0430\u043a, \u0447\u0442\u043e \u043a\u0430\u0436\u0434\u044b\u0439 SQL-\u0437\u0430\u043f\u0440\u043e\u0441 \u0441\u0442\u0430\u043d\u043e\u0432\u0438\u0442\u0441\u044f \u0434\u043e\u0447\u0435\u0440\u043d\u0438\u043c \u0441\u043f\u0430\u043d\u043e\u043c (CLIENT span) \u0432 \u0442\u0435\u043a\u0443\u0449\u0435\u043c \u0430\u043a\u0442\u0438\u0432\u043d\u043e\u043c \u0442\u0440\u0435\u0439\u0441\u0435.<\/p>\n
\u0412 xpenser \u0431\u0430\u0437\u0430 \u0441\u043e\u0437\u0434\u0430\u0451\u0442\u0441\u044f \u0447\u0435\u0440\u0435\u0437 @cleverbrush\/orm<\/code> (\u0440\u0435\u0447\u044c \u043e \u043d\u0435\u0439 \u043f\u043e\u0439\u0434\u0451\u0442 \u0432 \u0441\u043b\u0435\u0434\u0443\u044e\u0449\u0435\u0439 \u0441\u0442\u0430\u0442\u044c\u0435), \u0430 Knex \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435 \u043f\u0440\u0435\u0434\u0432\u0430\u0440\u0438\u0442\u0435\u043b\u044c\u043d\u043e \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442\u0438\u0440\u0443\u0435\u0442\u0441\u044f:<\/p>\n
import { createDb } from '@cleverbrush\/orm';import { instrumentKnex } from '@cleverbrush\/otel';import knex from 'knex';export function createDbResources(config: Config, logger: Logger): DbResources {    const connection = instrumentKnex(        knex({            client: 'pg',            connection: config.db.connectionString,            pool: { min: 2, max: 10 },            acquireConnectionTimeout: 10_000        })    );    logger.debug('Configured application database connection pool', {});    return {        knex: connection,        db: createDb(connection, entityMap)    };}<\/code>
<\/a><\/div><\/pre>\n
\u041f\u043e\u0441\u043b\u0435 \u044d\u0442\u043e\u0433\u043e \u0432 trace-\u043f\u0440\u043e\u0441\u043c\u043e\u0442\u0440\u0449\u0438\u043a\u0435 \u043a\u0430\u0436\u0434\u044b\u0439 SQL-\u0437\u0430\u043f\u0440\u043e\u0441 \u0432\u0438\u0434\u0435\u043d \u043a\u0430\u043a \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u044b\u0439 span \u0441 \u0442\u0435\u043a\u0441\u0442\u043e\u043c \u0437\u0430\u043f\u0440\u043e\u0441\u0430 \u0438 \u0434\u043b\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c\u044e.<\/p>\n
\"\u0422\u0440\u0435\u0439\u0441<\/p>\n
\u0422\u0440\u0435\u0439\u0441 \u0437\u0430\u043f\u0440\u043e\u0441\u0430 dashboard \u0432 SigNoz: web span, API span \u0438 \u0434\u043e\u0447\u0435\u0440\u043d\u0438\u0435 SQL spans<\/figcaption><\/div>\n<\/figure>\n
\u0421\u0432\u044f\u0437\u044c \u043b\u043e\u0433\u043e\u0432 \u0438 \u0442\u0440\u0435\u0439\u0441\u043e\u0432<\/h4>\n
\u0421\u0430\u043c\u0430\u044f \u043f\u043e\u043b\u0435\u0437\u043d\u0430\u044f \u043a\u043e\u043c\u0431\u0438\u043d\u0430\u0446\u0438\u044f: traceEnricher()<\/code> \u0434\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u0442 TraceId<\/code> \u0438 SpanId<\/code> \u0430\u043a\u0442\u0438\u0432\u043d\u043e\u0433\u043e \u0441\u043f\u0430\u043d\u0430 \u043a \u043a\u0430\u0436\u0434\u043e\u043c\u0443 \u043b\u043e\u0433-\u0441\u043e\u0431\u044b\u0442\u0438\u044e, \u0430 otelLogSink()<\/code> \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u0442 \u044d\u0442\u0438 \u0441\u043e\u0431\u044b\u0442\u0438\u044f \u0432 \u0442\u043e\u0442 \u0436\u0435 OTLP-\u043a\u043e\u043b\u043b\u0435\u043a\u0442\u043e\u0440.<\/p>\n
\u0412 API \u0438 web app xpenser \u044d\u0442\u043e \u0432\u044b\u0433\u043b\u044f\u0434\u0438\u0442 \u043e\u0434\u0438\u043d\u0430\u043a\u043e\u0432\u043e:<\/p>\n
const logger = createLogger({    minimumLevel: config.logLevel,    sinks: [consoleSink({ theme: 'dark' }), otelLogSink()],    enrichers: [hostnameEnricher(), processIdEnricher(), traceEnricher()]});<\/code>
<\/a><\/div><\/pre>\n
\u0422\u0435\u043f\u0435\u0440\u044c \u043b\u043e\u0433 \u0432\u043d\u0443\u0442\u0440\u0438 HTTP handler:<\/p>\n
logger.info(McpToolCalled, {    ToolName: toolName,    UserId: context.principal.userId,    ApiKeyId: context.principal.apiKeyId});<\/code>
<\/a><\/div><\/pre>\n
\u043e\u043a\u0430\u0437\u044b\u0432\u0430\u0435\u0442\u0441\u044f \u0441\u0432\u044f\u0437\u0430\u043d \u0441 trace, \u0432 \u043a\u043e\u0442\u043e\u0440\u043e\u043c \u044d\u0442\u043e\u0442 MCP-\u0437\u0430\u043f\u0440\u043e\u0441 \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u043b\u0441\u044f. \u0412 observability-\u0431\u044d\u043a\u0435\u043d\u0434\u0435 \u043c\u043e\u0436\u043d\u043e \u043d\u0430\u0447\u0430\u0442\u044c \u0441 \u043e\u0448\u0438\u0431\u043a\u0438 \u0432 \u043b\u043e\u0433\u0430\u0445, \u043f\u0435\u0440\u0435\u0439\u0442\u0438 \u043a trace \u0438 \u0443\u0432\u0438\u0434\u0435\u0442\u044c HTTP middleware, handler, \u043e\u0431\u0440\u0430\u0449\u0435\u043d\u0438\u044f \u043a \u0431\u0430\u0437\u0435 \u0438 \u0438\u0441\u0445\u043e\u0434\u044f\u0449\u0438\u0435 \u0437\u0430\u043f\u0440\u043e\u0441\u044b.<\/p>\n
\u041f\u043e\u043b\u043d\u0430\u044f \u043a\u0430\u0440\u0442\u0438\u043d\u0430: \u043a\u0430\u043a \u0432\u0441\u0451 \u0441\u043a\u043b\u0430\u0434\u044b\u0432\u0430\u0435\u0442\u0441\u044f \u0432\u043c\u0435\u0441\u0442\u0435<\/h3>\n
\u0412 xpenser \u043d\u0430\u0431\u043b\u044e\u0434\u0430\u0435\u043c\u043e\u0441\u0442\u044c \u0441\u043a\u043b\u0430\u0434\u044b\u0432\u0430\u0435\u0442\u0441\u044f \u0438\u0437 \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u0438\u0445 \u043d\u0435\u0431\u043e\u043b\u044c\u0448\u0438\u0445 \u0447\u0430\u0441\u0442\u0435\u0439:<\/p>\n