File tree Expand file tree Collapse file tree 1 file changed +0
-24
lines changed Expand file tree Collapse file tree 1 file changed +0
-24
lines changed Original file line number Diff line number Diff line change 4545import asyncio
4646import json
4747import os
48- import socket
4948from pathlib import Path
50- from urllib .parse import urlparse
5149
52- from aws_embedded_metrics .constants import DEFAULT_NAMESPACE
5350from aws_embedded_metrics .logger .metrics_logger_factory import create_metrics_logger
5451
5552
@@ -112,24 +109,3 @@ def get_metrics_logger():
112109 else :
113110 logger = None
114111 return MetricsWrapper (logger )
115-
116-
117- def emit_raw_emf (emf_msg : dict ):
118- """Emites a raw EMF log message to the local cloudwatch agent"""
119- if "AWS_EMF_AGENT_ENDPOINT" not in os .environ :
120- return
121-
122- namespace = os .environ .get ("AWS_EMF_NAMESPACE" , DEFAULT_NAMESPACE )
123- emf_msg ["_aws" ]["LogGroupName" ] = os .environ .get (
124- "AWS_EMF_LOG_GROUP_NAME" , f"{ namespace } -metrics"
125- )
126- emf_msg ["_aws" ]["LogStreamName" ] = os .environ .get ("AWS_EMF_LOG_STREAM_NAME" , "" )
127- for metrics in emf_msg ["_aws" ]["CloudWatchMetrics" ]:
128- metrics ["Namespace" ] = namespace
129-
130- emf_endpoint = urlparse (os .environ ["AWS_EMF_AGENT_ENDPOINT" ])
131- with socket .socket (socket .AF_INET , socket .SOCK_DGRAM ) as sock :
132- sock .sendto (
133- (json .dumps (emf_msg ) + "\n " ).encode ("utf-8" ),
134- (emf_endpoint .hostname , emf_endpoint .port ),
135- )
You can’t perform that action at this time.
0 commit comments