¿Cuál es la forma correcta de usar grupos de conexión en una aplicación de streaming pyspark?

Leohttps://forums.databricks.com/questions/3057/how-to-reuse-database-session-object-created-in-fo.html y entiendo que la forma correcta es usar un singleton para scala / java. ¿Es esto posible en Python? Un pequeño ejemplo de código sería muy apreciado. Creo que crear una conexión por Partición será muy ineficiente para una aplicación de transmisión.