span database #1608

sfc-gh-dkurokawa · 2024-11-14T16:45:33Z

Can you explain what's going on in this cell? Like how do we know the exporter is pointing at this collector?

sfc-gh-dkurokawa · 2024-11-14T16:47:27Z

This cell fails for me with the following error:

{ "name": "ConnectionError", "message": "HTTPConnectionPool(host='localhost', port=5000): Max retries exceeded with url: / (Caused by NewConnectionError('<urllib3.connection.HTTPConnection object at 0x30f03be50>: Failed to establish a new connection: [Errno 61] Connection refused'))", "stack": "--------------------------------------------------------------------------- ConnectionRefusedError Traceback (most recent call last) File ~/miniconda3/envs/trulens_3_11/lib/python3.11/site-packages/urllib3/connection.py:174, in HTTPConnection._new_conn(self) 173 try: --> 174 conn = connection.create_connection( 175 (self._dns_host, self.port), self.timeout, **extra_kw 176 ) 178 except SocketTimeout: File ~/miniconda3/envs/trulens_3_11/lib/python3.11/site-packages/urllib3/util/connection.py:95, in create_connection(address, timeout, source_address, socket_options) 94 if err is not None: ---> 95 raise err 97 raise socket.error(\"getaddrinfo returns an empty list\") File ~/miniconda3/envs/trulens_3_11/lib/python3.11/site-packages/urllib3/util/connection.py:85, in create_connection(address, timeout, source_address, socket_options) 84 sock.bind(source_address) ---> 85 sock.connect(sa) 86 return sock ConnectionRefusedError: [Errno 61] Connection refused During handling of the above exception, another exception occurred: NewConnectionError Traceback (most recent call last) File ~/miniconda3/envs/trulens_3_11/lib/python3.11/site-packages/urllib3/connectionpool.py:716, in HTTPConnectionPool.urlopen(self, method, url, body, headers, retries, redirect, assert_same_host, timeout, pool_timeout, release_conn, chunked, body_pos, **response_kw) 715 # Make the request on the httplib connection object. --> 716 httplib_response = self._make_request( 717 conn, 718 method, 719 url, 720 timeout=timeout_obj, 721 body=body, 722 headers=headers, 723 chunked=chunked, 724 ) 726 # If we're going to release the connection in ``finally:``, then 727 # the response doesn't need to know about the connection. Otherwise 728 # it will also try to release it and we'll have a double-release 729 # mess. File ~/miniconda3/envs/trulens_3_11/lib/python3.11/site-packages/urllib3/connectionpool.py:416, in HTTPConnectionPool._make_request(self, conn, method, url, timeout, chunked, **httplib_request_kw) 415 else: --> 416 conn.request(method, url, **httplib_request_kw) 418 # We are swallowing BrokenPipeError (errno.EPIPE) since the server is 419 # legitimately able to close the connection after sending a valid response. 420 # With this behaviour, the received response is still readable. File ~/miniconda3/envs/trulens_3_11/lib/python3.11/site-packages/urllib3/connection.py:244, in HTTPConnection.request(self, method, url, body, headers) 243 headers[\"User-Agent\"] = _get_default_user_agent() --> 244 super(HTTPConnection, self).request(method, url, body=body, headers=headers) File ~/miniconda3/envs/trulens_3_11/lib/python3.11/http/client.py:1303, in HTTPConnection.request(self, method, url, body, headers, encode_chunked) 1302 \"\"\"Send a complete request to the server.\"\"\" -> 1303 self._send_request(method, url, body, headers, encode_chunked) File ~/miniconda3/envs/trulens_3_11/lib/python3.11/http/client.py:1349, in HTTPConnection._send_request(self, method, url, body, headers, encode_chunked) 1348 body = _encode(body, 'body') -> 1349 self.endheaders(body, encode_chunked=encode_chunked) File ~/miniconda3/envs/trulens_3_11/lib/python3.11/http/client.py:1298, in HTTPConnection.endheaders(self, message_body, encode_chunked) 1297 raise CannotSendHeader() -> 1298 self._send_output(message_body, encode_chunked=encode_chunked) File ~/miniconda3/envs/trulens_3_11/lib/python3.11/http/client.py:1058, in HTTPConnection._send_output(self, message_body, encode_chunked) 1057 del self._buffer[:] -> 1058 self.send(msg) 1060 if message_body is not None: 1061 1062 # create a consistent interface to message_body File ~/miniconda3/envs/trulens_3_11/lib/python3.11/http/client.py:996, in HTTPConnection.send(self, data) 995 if self.auto_open: --> 996 self.connect() 997 else: File ~/miniconda3/envs/trulens_3_11/lib/python3.11/site-packages/urllib3/connection.py:205, in HTTPConnection.connect(self) 204 def connect(self): --> 205 conn = self._new_conn() 206 self._prepare_conn(conn) File ~/miniconda3/envs/trulens_3_11/lib/python3.11/site-packages/urllib3/connection.py:186, in HTTPConnection._new_conn(self) 185 except SocketError as e: --> 186 raise NewConnectionError( 187 self, \"Failed to establish a new connection: %s\" % e 188 ) 190 return conn NewConnectionError: <urllib3.connection.HTTPConnection object at 0x30f03be50>: Failed to establish a new connection: [Errno 61] Connection refused During handling of the above exception, another exception occurred: MaxRetryError Traceback (most recent call last) File ~/miniconda3/envs/trulens_3_11/lib/python3.11/site-packages/requests/adapters.py:667, in HTTPAdapter.send(self, request, stream, timeout, verify, cert, proxies) 666 try: --> 667 resp = conn.urlopen( 668 method=request.method, 669 url=url, 670 body=request.body, 671 headers=request.headers, 672 redirect=False, 673 assert_same_host=False, 674 preload_content=False, 675 decode_content=False, 676 retries=self.max_retries, 677 timeout=timeout, 678 chunked=chunked, 679 ) 681 except (ProtocolError, OSError) as err: File ~/miniconda3/envs/trulens_3_11/lib/python3.11/site-packages/urllib3/connectionpool.py:802, in HTTPConnectionPool.urlopen(self, method, url, body, headers, retries, redirect, assert_same_host, timeout, pool_timeout, release_conn, chunked, body_pos, **response_kw) 800 e = ProtocolError(\"Connection aborted.\", e) --> 802 retries = retries.increment( 803 method, url, error=e, _pool=self, _stacktrace=sys.exc_info()[2] 804 ) 805 retries.sleep() File ~/miniconda3/envs/trulens_3_11/lib/python3.11/site-packages/urllib3/util/retry.py:594, in Retry.increment(self, method, url, response, error, _pool, _stacktrace) 593 if new_retry.is_exhausted(): --> 594 raise MaxRetryError(_pool, url, error or ResponseError(cause)) 596 log.debug(\"Incremented Retry for (url='%s'): %r\", url, new_retry) MaxRetryError: HTTPConnectionPool(host='localhost', port=5000): Max retries exceeded with url: / (Caused by NewConnectionError('<urllib3.connection.HTTPConnection object at 0x30f03be50>: Failed to establish a new connection: [Errno 61] Connection refused')) During handling of the above exception, another exception occurred: ConnectionError Traceback (most recent call last) Cell In[3], line 1 ----> 1 res = requests.post(\"http://localhost:5000/\", json=json.dumps({\"key\": \"value\"})) 2 res.content File ~/miniconda3/envs/trulens_3_11/lib/python3.11/site-packages/requests/api.py:115, in post(url, data, json, **kwargs) 103 def post(url, data=None, json=None, **kwargs): 104 r\"\"\"Sends a POST request. 105 106 :param url: URL for the new :class:`Request` object. (...) 112 :rtype: requests.Response 113 \"\"\" --> 115 return request(\"post\", url, data=data, json=json, **kwargs) File ~/miniconda3/envs/trulens_3_11/lib/python3.11/site-packages/requests/api.py:59, in request(method, url, **kwargs) 55 # By using the 'with' statement we are sure the session is closed, thus we 56 # avoid leaving sockets open which can trigger a ResourceWarning in some 57 # cases, and look like a memory leak in others. 58 with sessions.Session() as session: ---> 59 return session.request(method=method, url=url, **kwargs) File ~/miniconda3/envs/trulens_3_11/lib/python3.11/site-packages/requests/sessions.py:589, in Session.request(self, method, url, params, data, headers, cookies, files, auth, timeout, allow_redirects, proxies, hooks, stream, verify, cert, json) 584 send_kwargs = { 585 \"timeout\": timeout, 586 \"allow_redirects\": allow_redirects, 587 } 588 send_kwargs.update(settings) --> 589 resp = self.send(prep, **send_kwargs) 591 return resp File ~/miniconda3/envs/trulens_3_11/lib/python3.11/site-packages/requests/sessions.py:703, in Session.send(self, request, **kwargs) 700 start = preferred_clock() 702 # Send the request --> 703 r = adapter.send(request, **kwargs) 705 # Total elapsed time of the request (approximately) 706 elapsed = preferred_clock() - start File ~/miniconda3/envs/trulens_3_11/lib/python3.11/site-packages/requests/adapters.py:700, in HTTPAdapter.send(self, request, stream, timeout, verify, cert, proxies) 696 if isinstance(e.reason, _SSLError): 697 # This branch is for urllib3 v1.22 and later. 698 raise SSLError(e, request=request) --> 700 raise ConnectionError(e, request=request) 702 except ClosedPoolError as e: 703 raise ConnectionError(e, request=request) ConnectionError: HTTPConnectionPool(host='localhost', port=5000): Max retries exceeded with url: / (Caused by NewConnectionError('<urllib3.connection.HTTPConnection object at 0x30f03be50>: Failed to establish a new connection: [Errno 61] Connection refused'))" }

-Original file line number
+Diff line change
@@ -0,0 +1,106 @@
+    {
+     "cells": [
+      {
+       "cell_type": "code",
+       "execution_count": null,
+       "metadata": {},
+       "outputs": [],
+       "source": [
+        "! pip install opentelemetry-exporter-otlp\n",
+        "! pip install \"fastapi[standard]\""
+       ]
+      },
+      {
+       "cell_type": "markdown",
+       "metadata": {},
+       "source": [
+        "# TruLens OTLP Collector Usage"
+       ]
+      },
+      {
+       "cell_type": "code",
+       "execution_count": null,
+       "metadata": {},
+       "outputs": [],
+       "source": [
+        "import json\n",
+        "\n",
+        "from opentelemetry import trace\n",
+        "from opentelemetry.exporter.otlp.proto.http.trace_exporter import (\n",
+        "    OTLPSpanExporter,\n",
+        ")\n",
+        "from opentelemetry.propagate import inject\n",
+        "from opentelemetry.sdk.trace import TracerProvider\n",
+        "from opentelemetry.sdk.trace.export import BatchSpanProcessor\n",
+        "import requests\n",
+        "from trulens.experimental.otel_tracing.core.otel import Collector\n",
+        "\n",
+        "tracer = trace.get_tracer(__name__)\n",
+        "\n",
+        "tracer_provider = TracerProvider()\n",
+        "trace.set_tracer_provider(tracer_provider)\n",
+        "span_processor = BatchSpanProcessor(\n",
+        "    OTLPSpanExporter(endpoint=\"http://localhost:5000\")\n",
+        ")\n",
+        "tracer_provider.add_span_processor(span_processor)\n",
+        "\n",
+        "with tracer.start_as_current_span(\"request\") as span:\n",
+        "    headers = {}\n",
+        "    inject(headers)\n",
+        "\n",
+        "print(headers)\n",
+        "\n",
+        "c = Collector()\n",
+        "c.start()"
+       ]
+      },
+      {
+       "cell_type": "code",
+       "execution_count": null,
+       "metadata": {},
+       "outputs": [],
+       "source": [
+        "res = requests.post(\"http://localhost:5000/\", json=json.dumps({\"key\": \"value\"}))\n",
+        "res.content"
+       ]
+      },
+      {
+       "cell_type": "code",
+       "execution_count": null,
+       "metadata": {},
+       "outputs": [],
+       "source": [
+        "from opentelemetry.exporter import otlp"
+       ]
+      },
+      {
+       "cell_type": "code",
+       "execution_count": null,
+       "metadata": {},
+       "outputs": [],
+       "source": [
+        "dir(otlp.proto.grpc)"
+       ]
+      }
+     ],
+     "metadata": {
+      "kernelspec": {
+       "display_name": "trulens-9bG3yHQd-py3.11",
+       "language": "python",
+       "name": "python3"
+      },
+      "language_info": {
+       "codemirror_mode": {
+        "name": "ipython",
+        "version": 3
+       },
+       "file_extension": ".py",
+       "mimetype": "text/x-python",
+       "name": "python",
+       "nbconvert_exporter": "python",
+       "pygments_lexer": "ipython3"
+      }
+     },
+     "nbformat": 4,
+     "nbformat_minor": 2
+    }

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

span database #1608

Diff view

Diff view

There are no files selected for viewing

sfc-gh-dkurokawa Nov 14, 2024

sfc-gh-dkurokawa Nov 14, 2024

span database #1608

Are you sure you want to change the base?

span database #1608

Diff view

Diff view

There are no files selected for viewing

sfc-gh-dkurokawa Nov 14, 2024

Choose a reason for hiding this comment

sfc-gh-dkurokawa Nov 14, 2024

Choose a reason for hiding this comment