The charge failed. Support has an email, a timestamp, and a screenshot. Orders wrote order.created. Payments wrote card_declined. Notifications wrote nothing. Three Cloud Run services, three log buckets, clocks that disagree by two seconds. Nobody can prove those lines belong to the same purchase.

That is not a shortage of console.log. It is a missing business identity.

A traceId is not a transactionId is the companion to this article. It defines the identifiers: transactionId is the payment, traceId is one run through the system, spanId is one step. This article is the NestJS half — how those fields get onto every log line, across HTTP and Pub/Sub, without passing them by hand.

The job is not to stamp a UUID onto a string and call it correlation. The job is to put TX-98431 on every event that belongs to that charge, including the worker that runs an hour later under a new trace.

A distributed request needs a business identity that follows it through gateways, APIs, workers, and systems you do not own. Structured logging is how transactionId becomes searchable. W3C traceparent is how the execution stays a tree. They are not the same field.

Logs without a join key are folklore

A monolith fails in one process. You open one file. A checkout in 2026 fails across processes you cannot attach to at the same time.

Gateway, Orders, Payment, and Notifications each write to their own stdout. Cloud Run collects those streams independently. If the only shared fact is “around 03:04 UTC”, you are aligning clocks and hoping the next request did not land in the same second.

Unstructured lines make that worse:

console.log("Payment failed for order 123");

That sentence cannot be filtered by service, joined to a worker, or counted by provider. The order id is English. The next engineer will write order #123 or OrderID=123. Grep becomes archaeology.

Timestamps are a weak join key:

  • instances are not perfectly synchronized.
  • retries land minutes later.
  • a worker may run an hour after the HTTP response.
  • two checkouts in the same second produce indistinguishable lines.

You need a field that is equal across every hop of this payment. Then the incident is a query, not a reconstruction. That field is transactionId. A hop-local requestId or a house correlationId will not survive the worker retry the companion article describes.

Structured logging is a contract, not a file format

Structured logging means each line is one event with a stable shape: a level, a message, and fields you will query. JSON is the usual encoding. JSON is not the strategy.

The console.log above is a string that happens to mention an order. This is an event:

{
  "level": "error",
  "event": "payment.failed",
  "transactionId": "TX-98431",
  "applicationId": "payment-service",
  "timestamp": "2026-08-15T08:04:12.331Z"
}

The second line is machine-readable. Cloud Logging stores it as jsonPayload. You filter jsonPayload.transactionId="TX-98431" and jsonPayload.event="payment.failed". You aggregate failures by paymentProvider without a regular expression. Support can ask for TX-98431 next week, after the original traceId has aged out.

A useful event has four kinds of data:

Piece Role Example
Level How urgent is this line error
Event What happened, as a stable name payment.failed
Context Which operation, which service transactionId, applicationId
Message Human sentence for the timeline Payment processing failed

Keep event names boring and consistent: order.created, payment.started, payment.failed. Treat them like API paths. If every service invents its own vocabulary, you are back to folklore with extra braces.

Dumping an object as JSON is not structured logging. logger.info({ req }, "request") is a structured leak. Designing the fields is the work.

A context you can actually run

For a NestJS estate on Cloud Run, this is the set that pays rent:

sequenceDiagram
    participant C as Client
    participant G as API Gateway
    participant O as Orders API
    participant P as Payment API
    participant N as Notification Worker

    C->>G: Request<br/>x-request-id (optional hop token)

    Note over G: requestId = this hop<br/>applicationId = api-gateway<br/>No transactionId yet

    G->>O: Request
    Note over O: Mint transactionId = TX-98431<br/>applicationId = orders-api

    O->>P: HTTP<br/>x-transaction-id: TX-98431
    Note over P: Same transactionId

    O->>N: Pub/Sub<br/>attributes.transactionId = TX-98431
    Note over N: applicationId = notification-worker<br/>Same transactionId<br/>Possibly new traceId

Rules that keep the set small:

  1. The domain owns transactionId. Orders (or Payments) mints TX-98431 when the business record exists. Accept an inbound x-transaction-id only if it matches a tight allowlist — same discipline as a UUID, different charset (TX- plus digits, or your house format). Echo it on the response so support can file a ticket with a real id.
  2. The edge owns requestId. Accept x-request-id / x-correlation-id when it is a UUID. Otherwise mint crypto.randomUUID(). This covers hops that happen before TX-98431 exists. It is not the incident join key.
  3. Every service writes applicationId locally. Do not trust the caller to tell you who you are.
  4. traceId / spanId appear when a tracer is on. Propagate W3C traceparent in parallel. Do not replace transactionId with it. Do not replace traceparent with x-transaction-id.

A log line from Payment should look like this — fields, not a paragraph:

{
  "severity": "ERROR",
  "message": "Payment processing failed",
  "event": "payment.failed",
  "transactionId": "TX-98431",
  "applicationId": "payment-api",
  "paymentProvider": "stripe",
  "errorCode": "card_declined"
}

Same transactionId in Orders, Payment, and the worker. Different applicationId on each line. A later retry may carry a different traceId. You still find the payment.

Implementation: NestJS, Pino, and a context you do not thread by hand

The stack is boring on purpose: NestJS, TypeScript, Pino, nestjs-pino, and Node’s AsyncLocalStorage.

nestjs-pino wraps pino-http. Each inbound HTTP request gets a child logger. Logger and PinoLogger read that child through AsyncLocalStorage, so a service three layers down inherits req.id without seeing the request. That is why you should not write this in every method:

this.logger.info({ transactionId }, "Payment started");

If you are typing transactionId at the call site after the order exists, the context is not bound.

Register LoggerModule.forRoot once, in the root module. The library is @Global(). A second import registers pino-http again and doubles every access log. The failure is silent.

import { randomUUID } from "node:crypto";
import { Module } from "@nestjs/common";
import { LoggerModule } from "nestjs-pino";
import type { IncomingMessage, ServerResponse } from "node:http";
import { headerValue, isUuid, SERVICE_NAME } from "./request-context";

const REQUEST_ID_HEADER = "x-request-id";

function resolveRequestId(req: IncomingMessage): string {
  const incoming =
    headerValue(req.headers[REQUEST_ID_HEADER]) ?? headerValue(req.headers["x-correlation-id"]);
  return incoming && isUuid(incoming) ? incoming : randomUUID();
}

@Module({
  imports: [
    LoggerModule.forRoot({
      pinoHttp: {
        level: process.env.NODE_ENV === "production" ? "info" : "debug",
        genReqId: (req: IncomingMessage, res: ServerResponse) => {
          const requestId = resolveRequestId(req);
          res.setHeader(REQUEST_ID_HEADER, requestId);
          return requestId;
        },
        customProps: (req) => ({
          requestId: req.id,
          applicationId: SERVICE_NAME,
        }),
        redact: {
          paths: [
            "req.headers.authorization",
            "req.headers.cookie",
            'res.headers["set-cookie"]',
            'req.headers["x-api-key"]',
            "req.body.password",
            "req.body.accessToken",
            "req.body.refreshToken",
            "req.body.cvv",
            "req.body.cardNumber",
            "*.secret",
          ],
          censor: "[Redacted]",
        },
        autoLogging: {
          ignore: (req) => req.url === "/health" || req.url === "/ready",
        },
      },
    }),
  ],
})
export class AppModule {}

genReqId is the pino-http hook the nestjs-pino FAQ points at for X-Request-ID. Use it for the hop id. Echo it on the response. It is not TX-98431. Clients that retry a create before an order exists still need some id; support that asks about a payment next week needs the transaction.

Validate inbound identifiers. A 4 KB header that contains spaces, quotes, or a crafted payload will end up in every downstream log. A UUID is a tight allowlist for requestId. transactionId gets its own charset (TX- plus digits, or whatever you mint). Do not accept “whatever the caller sent.”

Wire the logger in main.ts the way Nest and nestjs-pino both document. bufferLogs keeps early bootstrap lines until Pino is ready:

import { NestFactory } from "@nestjs/core";
import { Logger } from "nestjs-pino";
import { AppModule } from "./app.module";
import { LoggerErrorInterceptor } from "nestjs-pino";

async function bootstrap() {
  const app = await NestFactory.create(AppModule, { bufferLogs: true });
  app.useLogger(app.get(Logger));
  app.useGlobalInterceptors(new LoggerErrorInterceptor());
  await app.listen(process.env.PORT ?? 3000);
}

bootstrap();

LoggerErrorInterceptor copies the real exception onto the response so the automatic request errored line contains the error you threw, not a generic Error.

In services, use Nest’s Logger. After app.useLogger(), those calls go to Pino and inherit the request child:

import { Injectable, Logger } from "@nestjs/common";

@Injectable()
export class PaymentsService {
  private readonly logger = new Logger(PaymentsService.name);

  async charge(transactionId: string, paymentProvider: string): Promise<void> {
    this.logger.log({ event: "payment.started", paymentProvider }, "Charging card");

    try {
      await this.provider.charge(transactionId);
    } catch (error) {
      const errorCode = this.providerErrorCode(error);
      this.logger.error(
        { event: "payment.failed", paymentProvider, errorCode },
        "Payment processing failed",
      );
      throw error;
    }
  }
}

No transactionId in the call. Once Orders assigned it, every later line on this request already has it.

Use PinoLogger.assign() when the business id appears — that is the moment TX-98431 starts to exist. Also assign a userId after auth if you will query it. Do not assign a second UUID and call it the transaction:

import { Controller, Post, Body, Res } from "@nestjs/common";
import type { Response } from "express";
import { PinoLogger } from "nestjs-pino";
import { setTransactionId } from "./request-context";

@Controller("orders")
export class OrdersController {
  constructor(
    private readonly logger: PinoLogger,
    private readonly orders: OrdersService,
  ) {
    this.logger.setContext(OrdersController.name);
  }

  @Post()
  async create(@Body() body: CreateOrderDto, @Res({ passthrough: true }) res: Response) {
    const order = await this.orders.create(body);
    this.logger.assign({ transactionId: order.transactionId });
    setTransactionId(order.transactionId);
    res.setHeader("x-transaction-id", order.transactionId);
    return order;
  }
}

assign is request-scoped. It is not a global mutable logger. That is the point.

If Payment is called on a later request, read x-transaction-id in middleware and assign it immediately — do not mint a new TX-. The business id is cargo. You forward it; you do not reinvent it.

AsyncLocalStorage for hops that are not HTTP

nestjs-pino’s store dies at the edge of the HTTP request. Outbound clients and Pub/Sub publishers still need to read transactionId. Workers that never went through pino-http need to restore it.

A thin store is enough. Nest documents the same pattern in the Async local storage recipe.

import { AsyncLocalStorage } from "node:async_hooks";

export const SERVICE_NAME = process.env.APPLICATION_ID ?? "orders-api";

export type RequestContext = {
  requestId: string;
  applicationId: string;
  transactionId?: string;
};

export const requestAls = new AsyncLocalStorage<RequestContext>();

export function getTransactionId(): string | undefined {
  return requestAls.getStore()?.transactionId;
}

export function setTransactionId(transactionId: string) {
  const store = requestAls.getStore();
  if (store) store.transactionId = transactionId;
}

export function headerValue(value: string | string[] | undefined): string | undefined {
  if (Array.isArray(value)) return value[0];
  return value;
}

export function isUuid(value: string): boolean {
  return /^[0-9a-f]{8}-[0-9a-f]{4}-[1-8][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/i.test(value);
}

export function isTransactionId(value: string): boolean {
  return /^TX-[A-Z0-9]{4,32}$/.test(value);
}

Enter the store after pino-http has set req.id. If the caller already has TX-98431, bind it here so Payment never waits on Orders to assign it again:

import { Injectable, NestMiddleware } from "@nestjs/common";
import type { NextFunction, Request, Response } from "express";
import { headerValue, isTransactionId, requestAls, SERVICE_NAME } from "./request-context";

@Injectable()
export class RequestContextMiddleware implements NestMiddleware {
  use(req: Request, res: Response, next: NextFunction) {
    const incoming = headerValue(req.headers["x-transaction-id"]);
    const transactionId = incoming && isTransactionId(incoming) ? incoming : undefined;
    if (transactionId) {
      res.setHeader("x-transaction-id", transactionId);
    }

    requestAls.run({ requestId: String(req.id), applicationId: SERVICE_NAME, transactionId }, () =>
      next(),
    );
  }
}

Two stores, two jobs. nestjs-pino binds logs. Yours binds outbound I/O. Do not invent a third. If transactionId was on the inbound header, also assign it onto the child logger in this middleware (or a tiny interceptor) so every line of the hop carries TX-98431.

Propagate on every HTTP call

The id is useless if Service B never sees it.

sequenceDiagram
    participant A as Service A
    participant B as Service B
    participant C as Service C

    A->>B: HTTP<br/>x-transaction-id: TX-98431<br/>traceparent: 00-…

    B->>C: HTTP<br/>x-transaction-id: TX-98431

Nest’s HTTP client is HttpService from @nestjs/axios. Configure Axios once through axiosRef. Do not add the header in each service method.

import { Injectable, OnModuleInit } from "@nestjs/common";
import { HttpService } from "@nestjs/axios";
import { getTransactionId } from "./request-context";

@Injectable()
export class OutboundTransactionInterceptor implements OnModuleInit {
  constructor(private readonly http: HttpService) {}

  onModuleInit() {
    this.http.axiosRef.interceptors.request.use((config) => {
      const transactionId = getTransactionId();
      if (transactionId) {
        config.headers.set("x-transaction-id", transactionId);
      }
      return config;
    });
  }
}

Register that provider in the same module that imports HttpModule. Every this.http.post(...) now forwards the payment. Service B’s middleware accepts TX-98431 and assigns it.

If you also run OpenTelemetry, forward traceparent / tracestate with the official propagator. That is a different header and a different job. x-transaction-id is cargo. traceparent is the execution passport. The companion article is explicit: do not replace one with the other. Send both.

What breaks the chain:

  • a raw fetch or undici call that bypasses HttpService.
  • a cron that starts work with no inbound transactionId and never loads one from the job payload.
  • a third-party SDK that opens its own HTTP agent.

Wrap those the same way: read getTransactionId(), set the header, or refuse to call out without a store once the business record exists.

Propagate through Pub/Sub and jobs

HTTP headers die at the response. The notification email is sent by a worker that was not on the socket.

Pub/Sub messages have data and optional attributes: string key-value pairs, at most 100, keys ≤ 256 bytes, values ≤ 1024 bytes. Google documents attributes for metadata such as timestamps and transaction ids. That is the transport.

import { PubSub } from "@google-cloud/pubsub";
import { getTransactionId, SERVICE_NAME } from "./request-context";

const pubsub = new PubSub();

export async function publishOrderEvent(event: string, payload: Record<string, unknown>) {
  const transactionId = getTransactionId();
  if (!transactionId) {
    throw new Error("Refusing to publish without a transactionId");
  }

  await pubsub.topic("order-events").publishMessage({
    json: { event, ...payload },
    attributes: {
      transactionId,
      applicationId: SERVICE_NAME,
    },
  });
}

Prefer attributes over stuffing a metadata object into data:

{
  "data": { "event": "order.payment_failed" },
  "attributes": {
    "transactionId": "TX-98431",
    "applicationId": "orders-api"
  }
}

Attributes are filterable on the subscription. They survive a change to the payload schema. They stay out of the business document. A nested metadata block inside data works if every consumer remembers to look there. The next schema, the next language, and the next intern will not.

The worker must restore the store before it logs or publishes again. A push subscription is an HTTP request: copy attributes.transactionId onto x-transaction-id and let the middleware bind it. A pull worker has no pino-http child, and PinoLogger.assign() throws outside a request (unable to assign extra fields out of request scope). Build a child logger with the fields instead:

import { Injectable } from "@nestjs/common";
import { PinoLogger } from "nestjs-pino";
import { isTransactionId, requestAls, SERVICE_NAME } from "./request-context";
import { randomUUID } from "node:crypto";

@Injectable()
export class NotificationWorker {
  constructor(private readonly pino: PinoLogger) {}

  async handle(message: { attributes: Record<string, string>; data: Buffer }) {
    const incoming = message.attributes.transactionId;
    if (!incoming || !isTransactionId(incoming)) {
      this.pino.error({ event: "notification.orphaned" }, "Message missing transactionId");
      return;
    }

    const logger = this.pino.logger.child({ transactionId: incoming, applicationId: SERVICE_NAME });

    await requestAls.run(
      { requestId: randomUUID(), applicationId: SERVICE_NAME, transactionId: incoming },
      async () => {
        logger.info({ event: "notification.started" }, "Sending payment-failed email");
        // pass `logger` down, or publish with getTransactionId() as before
      },
    );
  }
}

If the attribute is missing, do not mint a new TX-. A silent new transaction id is how a retry becomes a second payment in the logs. Drop to dead-letter, or log notification.orphaned and stop.

The same restore step applies to Bull, Cloud Tasks, and cron. The transport changes. The rule does not: whoever starts work must enter the store with the business id. HTTP middleware does it for requests. The consumer does it for messages. The scheduler does it for jobs.

Three different mechanisms, one purpose:

Mechanism Carrier Restored by
HTTP propagation x-transaction-id middleware + assign
Message propagation Pub/Sub attributes (or job metadata) the consumer, via requestAls.run
Request context AsyncLocalStorage in-process nothing — it does not cross a process
Distributed tracing W3C traceparent the OpenTelemetry propagator

Do not expect ALS to survive a publish. Do not expect traceparent to survive a worker that never extracted it. Copy transactionId onto the message. The worker’s new traceId is expected. The companion article already drew that graph.

Cloud Run: three services, three streams, one query

Put Orders, Payment, and Notifications on Cloud Run and the platform will do exactly what it promises: collect stdout from each service into Cloud Logging, tagged with that service’s resource. It will not notice that the three streams are one purchase.

Without a shared field you open three services in Logs Explorer and scroll. With transactionId on every JSON line, one query rebuilds the purchase — including the worker that ran later:

jsonPayload.transactionId="TX-98431"

Cloud Run logging parses each stdout line. A JSON object becomes jsonPayload. A plain string becomes textPayload. textPayload is what you get from console.log("Payment failed"). You will search it with substrings until you stop.

Cloud Logging also lifts special fields out of the JSON onto the LogEntry. The ones that matter here:

JSON field LogEntry field Why you set it
severity severity Filter by level without parsing Pino’s numeric level
message display text The sentence in the timeline
logging.googleapis.com/trace trace Nest this line under the request log and join Cloud Trace
logging.googleapis.com/spanId spanId Which span produced the line
logging.googleapis.com/trace_sampled traceSampled Whether a span was stored

Pino’s defaults are level: 30 and msg. Cloud Logging does not treat those as special. Map them once:

const SEVERITY: Record<string, string> = {
  trace: "DEBUG",
  debug: "DEBUG",
  info: "INFO",
  warn: "WARNING",
  error: "ERROR",
  fatal: "CRITICAL",
};

// inside pinoHttp:
{
  messageKey: "message",
  formatters: {
    level(label) {
      return { severity: SEVERITY[label] ?? label.toUpperCase() };
    },
  },
}

Cloud Run’s own sample still reads X-Cloud-Trace-Context and writes logging.googleapis.com/trace as projects/PROJECT_ID/traces/TRACE_ID; the LogEntry reference now recommends the raw TRACE_ID and keeps the resource name only for compatibility. Prefer traceparent when it is present — Cloud Run sets it on inbound service requests — and keep the legacy header as fallback. Add that to customProps:

function cloudTrace(req: IncomingMessage): Record<string, string> {
  const traceparent = headerValue(req.headers.traceparent);
  const w3c = traceparent?.split("-");
  if (w3c?.[0] === "00" && w3c[1] && w3c[1] !== "0".repeat(32)) {
    return {
      "logging.googleapis.com/trace": w3c[1],
      "logging.googleapis.com/spanId": w3c[2] ?? "",
    };
  }

  const legacy = headerValue(req.headers["x-cloud-trace-context"]);
  const traceId = legacy?.split("/")[0];
  if (traceId) {
    return {
      "logging.googleapis.com/trace": traceId,
    };
  }

  return {};
}

Container logs nest under the request log in Logs Explorer only when they share that trace field. Writing JSON is not enough. Writing transactionId is enough to search across services even when the trace was not sampled — the companion article notes that traceSampled: false is still a valid join to logs, not proof the request never happened. Use both: transactionId for the payment, trace for the platform join.

Retention is a product decision. A transactionId you cannot query after 24 hours is a postmortem you cannot finish. Set a retention that matches how long support still asks “what happened to this payment?”

Do not log the request

Redaction is not a courtesy. Logs are a durable store with a wider audience than the production database: on-call, contractors, SIEM exporters, the next intern with Logs Explorer access.

Never write:

  • passwords and password hashes.
  • access tokens, refresh tokens, session tokens.
  • cookies and Set-Cookie.
  • Authorization and API keys.
  • full payment payloads, PAN, CVV, expiry, bank account numbers.
  • secrets, private keys, connection strings.
  • personal data you do not need in order to debug (email is often enough; a national id never is).

This line is how those values escape:

this.logger.log({ req }, "incoming request");

pino-http already serializes a request object onto the access log. That object includes headers. If you also pass req or req.body from a handler, you get the body, the bearer token, and whatever the client posted as cvv. redact is a safety net, not a license. The list in the LoggerModule config above is that net; extend it as new secret-bearing fields appear.

Pino redacts paths you list, at serialization time, using fast-redact. Paths are case-sensitive. Hyphenated headers need bracket notation. Wildcards exist (*.secret, users[*].password). User input must never define those paths — the library evaluates them in a VM.

Defense in layers:

  1. Do not log the object. Log event, transactionId, errorCode. That is an allowlist.
  2. Redact known secret paths so an access log or a future logger.log({ req }) cannot leak them.
  3. Classify fields in the DTO: identifiers are fine, credentials are not, PII is a decision.
  4. Disable body serialization on the access log if you do not need it. You almost never need it.

censor: "[Redacted]" still tells you the key existed. remove: true drops the key. For tokens, either is fine. For CVV, prefer never having the path in the logger at all.

Levels are a budget

Pino’s levels are trace, debug, info, warn, error, fatal. Nest’s Logger maps verbose → trace and log → info. Production should not default to debug.

Level When Example Production?
trace Instruction-level noise Entered mapProviderError No
debug Local diagnosis, feature flags, raw provider payloads you have already redacted Provider response id, retry attempt Sampled or off
info A state change you will want in an incident timeline order.created, payment.started Yes, for sparse business events
warn Recoverable, but someone should look Provider timeout, then retry; dropped optional notification Yes
error This unit of work failed payment.failed, unhandled handler exception Yes
fatal The process should not continue Failed to boot, lost the database pool, out of memory Yes, and rare

A good log system lets you investigate an incident without producing millions of irrelevant lines.

/health at info on every instance, every ten seconds, is how you bury payment.failed. Successful GETs of a public catalog at info are the same firehose. Keep automatic HTTP completion logs, or drop 2xx to debug with customLogLevel and keep 5xx at error.

customLogLevel: (_req, res, err) => {
  if (res.statusCode >= 500 || err) return "error";
  if (res.statusCode >= 400) return "warn";
  return "info";
},

Even that info on every 200 will dominate a high-QPS service. Ignore health. Sample or silence the rest if the stream is the product.

Do not log error for a 404 the client caused, or info for a declined card you already handle. A decline is a business outcome: warn or info with event=payment.failed is enough unless the provider call itself threw.

3:00 AM — a payment failed

A customer writes: the card was charged, or was not, and the app showed an error. They include TX-98431 from the receipt, or you find x-transaction-id on the response.

1. Search the transaction id. In Cloud Logging: jsonPayload.transactionId="TX-98431". Do not start with the timestamp. Do not start with a house correlation UUID.

2. Land in Orders. event=order.created, applicationId=orders-api. The request reached you. The business record exists.

3. Follow Payment. Same transactionId. event=payment.started, then event=payment.failed, errorCode=card_declined, paymentProvider=stripe. The failure is the provider’s decline, not a 500 in Orders. Note the traceId on those lines — that is the HTTP checkout.

4. Read the provider fields you allowed. An errorCode and a provider request id, not the card. If those fields are missing, the next incident will be this one again.

5. Check the worker. applicationId=notification-worker, event=notification.payment_failed.sent — or no line at all. The traceId here may be def789. That is not a different payment. It is the second execution the companion article warned about.

6. Say where it actually failed. Not “payments is down.” The card was declined. Orders recorded it. The user should have received the email. If they did not, the worker is the page, not the charge.

That walk is the reason the rest of the article exists. MTTR is the time to the field, not the time to the theory.

transactionId is minted in Orders and copied onto every arrow after that; applicationId is written by each box; traceId follows the synchronous HTTP path and may restart in the worker. In code, that is seven pieces:

  1. LoggerModule.forRoot once. genReqId for the hop, customProps for applicationId, redact, health ignore.
  2. RequestContextMiddleware enters AsyncLocalStorage and binds inbound x-transaction-id.
  3. Controllers assign({ transactionId }) when the business record is created.
  4. OutboundTransactionInterceptor on HttpService.axiosRef.
  5. Publishers copy getTransactionId() into message attributes.
  6. Consumers enter requestAls.run with the same transactionId and log through a child logger before they log or publish.
  7. Optional: OpenTelemetry SDK. Same store, traceparent on a different header.

The request has to remain reconstructable

A production failure is a path. Structured logging makes each step a row; transactionId makes those rows one result set, including the worker that opened a second traceId. Redaction keeps that result set from becoming a breach. Levels keep it from becoming noise. When that is in place, “what happened to this payment?” is a filter, not a timestamp hunt.

Sources