stor_opts

Author: deanm0000

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "dean_utils"
-version="0.0.59"
+version="0.0.60"
 authors=[
     { name="Dean MacGregor", email="powertrading121@gmail.com"}
 ]

src/dean_utils/__init__.py

@@ -1,3 +1,5 @@
+from __future__ import annotations
+
 __all__ = [
     "async_abfs",
     "az_send",
@@ -14,6 +16,7 @@
     "update_queue",
 ]
 import contextlib
+import os
 
 from dean_utils.polars_extras import (
     pl_scan_hive,
@@ -65,3 +68,22 @@ def wrapper(*args, **kwargs):
         )
 
     return wrapper
+
+
+def stor_opts(os_env: str = "Synblob") -> dict[str, str]:
+    conn_str = os.environ.get(os_env)
+    assert conn_str is not None
+    return {
+        k: y[1]
+        for x in conn_str.split(";")
+        if (k := _name_key((y := x.split("="))[0])) is not None
+    }
+
+
+def _name_key(x: str) -> str | None:
+    if x == "AccountName":
+        return "account_name"
+    elif x == "AccountKey":
+        return "account_key"
+    else:
+        return None