1

我一直在使用谷歌云 kubernetes 遇到谷歌云日志记录和谷歌云跟踪问题

我有使用 gcloud pubsub 主题的应用程序，我想统一日志以跟踪每个 pubsub 消息句柄 func 调用

我的 Gcloud 日志记录处理程序代码

class GCLHandler(CloudLoggingHandler):
    def emit(self, record):
        message = super(GCLHandler, self).format(record)

        resource = Resource(
            type='k8s_container',
            labels={
                'cluster_name': os.environ['CLUSTER_NAME'],
                'container_name': os.environ['POD_APP_NAME'],
                'location': os.environ['CLUSTER_LOCATION'],
                'namespace_name': os.environ['POD_NAMESPACE'],
                'pod_name': os.environ['POD_NAME'],
                'project_id': _settings.PROJECT_NAME
            }
        )

        labels: Dict[str, Any] = {
            'k8s-pod/app': os.environ['POD_APP_NAME'],
            'k8s-pod/app_kubernetes_io/managed-by': os.environ['POD_MANAGED_BY'],
            'k8s-pod/pod-template-hash': os.environ['POD_TEMPLATE_HASH']
        }
        trace = getattr(record, 'traceId', None)
        if trace is not None:
            trace = f'projects/{_settings.PROJECT_NAME}/traces/{trace}'
        self.transport.send(
            record,
            message,
            resource=resource,
            labels=labels,
            trace=trace,
            span_id=getattr(record, 'spanId', None)
        )

我使用与 gcloud 跟踪和日志记录的 opensensus 集成，因此我可以获取 traceId 和 spanId 并将其传递到 gcloud 日志传输，它工作正常，并且日志查看器中的 LogEntry 包含正确的 traceId 和 spanId

我使用 gcloud trace 的代码看起来像

config_integration.trace_integrations(['logging'])
logger = logging.getLogger(__name__)

exporter = stackdriver_exporter.StackdriverExporter(
    project_id=settings.PROJECT_NAME
)


async def handle_message(message: Message) -> None:
    tracer = Tracer(exporter=exporter, sampler=AlwaysOnSampler())
    with tracer.span(name=f'Message#{message.message_id}'):
        logger.debug(f'debug')
        logger.info(f'info')
        logger.warning(f'warning')

所以，我可以在 Logs Viewer 中查看这些日志，但它们不会在一个跟踪中找到，但是如果我使用 gcloud trace viewer 并通过 traceId 搜索，我会找到这个带有连接日志的跟踪。问：有什么方法可以在日志查看器中显示跟踪，因为它在任何 appengine 服务中显示为 appengine.googleapis.com/Frequest_log？

4

1 回答 1

0

正如@Nikita Davydov在评论部分证实的那样，有一个解决方法：您可以创建一个虚假的http_request有效负载来分组日志。

如果它不适合您，您可以在Google Public Issue Tracker提交功能请求以更改当前行为。

于 2020-11-10T07:44:09.650 回答