fix tls bugs

Author: yaozheng-fang

veadk/integrations/ve_faas/template/{{cookiecutter.local_dir_name}}/deploy.py

@@ -95,8 +95,8 @@ async def main():
         message = "How is the weather like in Beijing?"
         print(f"Test message: {message}")
 
-        await _send_msg_with_a2a(cloud_app=cloud_app, message=message)
-        await _send_msg_with_mcp(cloud_app=cloud_app, message=message)
+        # await _send_msg_with_a2a(cloud_app=cloud_app, message=message)
+        # await _send_msg_with_mcp(cloud_app=cloud_app, message=message)
 
 
 if __name__ == "__main__":

veadk/integrations/ve_tls/utils.py

@@ -80,7 +80,7 @@ def __prepare_request(
     return request
 
 
-async def ve_tls_request(
+def ve_tls_request(
     client: TLSService,
     api: str,
     params: dict | None = None,
@@ -100,10 +100,10 @@ async def ve_tls_request(
 
     url = request.build()
 
-    async with httpx.AsyncClient() as session:
+    with httpx.Client() as session:
         while True:
             try:
-                response = await session.request(
+                response = session.request(
                     method=method,
                     url=url,
                     headers=request.headers,

veadk/integrations/ve_tls/ve_tls.py

@@ -12,13 +12,13 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-import asyncio
 import os
 
+from volcengine.tls.TLSService import TLSService
+
 from veadk.consts import DEFAULT_TLS_LOG_PROJECT_NAME, DEFAULT_TLS_TRACING_INSTANCE_NAME
 from veadk.integrations.ve_tls.utils import ve_tls_request
 from veadk.utils.logger import get_logger
-from volcengine.tls.TLSService import TLSService
 
 logger = get_logger(__name__)
 
@@ -63,13 +63,11 @@ def get_project_id_by_name(self, project_name: str) -> str:
 
         try:
             res = None
-            res = asyncio.run(
-                ve_tls_request(
-                    client=self._client,
-                    api="DescribeProjects",
-                    body=request_body,
-                    method="GET",
-                )
+            res = ve_tls_request(
+                client=self._client,
+                api="DescribeProjects",
+                body=request_body,
+                method="GET",
             )
             projects = res["Projects"]
             for project in projects:
@@ -97,10 +95,8 @@ def create_log_project(self, project_name: str) -> str:
             "Tags": [{"Key": "provider", "Value": "VeADK"}],
         }
         try:
-            res = asyncio.run(
-                ve_tls_request(
-                    client=self._client, api="CreateProject", body=request_body
-                )
+            res = ve_tls_request(
+                client=self._client, api="CreateProject", body=request_body
             )
 
             if res["ErrorCode"] == "ProjectAlreadyExist":
@@ -122,13 +118,11 @@ def get_trace_instance_by_name(self, log_project_id: str, trace_instance_name: s
             "TraceInstanceName": trace_instance_name,
         }
         try:
-            res = asyncio.run(
-                ve_tls_request(
-                    client=self._client,
-                    api="DescribeTraceInstances",
-                    body=request_body,
-                    method="GET",
-                )
+            res = ve_tls_request(
+                client=self._client,
+                api="DescribeTraceInstances",
+                body=request_body,
+                method="GET",
             )
 
             for instance in res["TraceInstances"]:
@@ -156,12 +150,10 @@ def create_tracing_instance(self, log_project_id: str, trace_instance_name: str)
 
         try:
             res = None
-            res = asyncio.run(
-                ve_tls_request(
-                    client=self._client,
-                    api="CreateTraceInstance",
-                    body=request_body,
-                )
+            res = ve_tls_request(
+                client=self._client,
+                api="CreateTraceInstance",
+                body=request_body,
             )
 
             if res["ErrorCode"] == "TopicAlreadyExist":
@@ -173,13 +165,11 @@ def create_tracing_instance(self, log_project_id: str, trace_instance_name: str)
                 )
 
             # after creation, get the trace instance details
-            res = asyncio.run(
-                ve_tls_request(
-                    client=self._client,
-                    api="DescribeTraceInstance",
-                    body={"TraceInstanceID": res["TraceInstanceID"]},
-                    method="GET",
-                )
+            res = ve_tls_request(
+                client=self._client,
+                api="DescribeTraceInstance",
+                body={"TraceInstanceID": res["TraceInstanceID"]},
+                method="GET",
             )
 
             return res

veadk/tracing/telemetry/exporters/apmplus_exporter.py

@@ -117,7 +117,6 @@ class APMPlusExporter(BaseExporter):
     config: APMPlusExporterConfig = Field(default_factory=APMPlusExporterConfig)
 
     def model_post_init(self, context: Any) -> None:
-        print(self.config)
         headers = {
             "x-byteapm-appkey": self.config.app_key,
         }