I have a postgres cluster deployed in kubernetes and I am doing port-forwarding so that I can access the pod from outside the kubernetes cluster
from kubernetes.stream import portforward
pf = portforward(
self.core_v_api.connect_get_namespaced_pod_portforward,
name, namespace,
ports=str(ports),
)
return pfThis returns me a websocket:
<websocket._core.WebSocket object at 0x7ff628132c50>I have to use this WebSocket to connect with the Postgres, is there a way I can use psycopg2 with a custom WebSocket or any other way?