Qual é a maneira correta de usar pools de conexão em um aplicativo pyspark de streaming?

Eu li atravéshttps://forums.databricks.com/questions/3057/how-to-reuse-database-session-object-created-in-fo.html e entender a maneira correta é usar um singleton para scala / java. Isso é possível em python? Um pequeno exemplo de código seria muito apreciado. Acredito que a criação de uma conexão por Partição será muito ineficiente para um aplicativo de streaming.