further sdk module/docs/example updates

vdice · vdice · commit 71ea2b648157 · 2026-04-03T14:45:01.000-06:00
Signed-off-by: Vaughn Dice &lt;vdice@akamai.com&gt;
diff --git a/docs/v4/http/index.html b/docs/v4/http/index.html
diff --git a/docs/v4/key_value.html b/docs/v4/key_value.html
diff --git a/docs/v4/mqtt.html b/docs/v4/mqtt.html
diff --git a/docs/v4/postgres.html b/docs/v4/postgres.html
diff --git a/docs/v4/redis.html b/docs/v4/redis.html
diff --git a/docs/v4/sqlite.html b/docs/v4/sqlite.html
diff --git a/docs/v4/variables.html b/docs/v4/variables.html
diff --git a/examples/spin-kv/app.py b/examples/spin-kv/app.py
@@ -3,13 +3,13 @@
 
 class WasiHttpHandler030Rc20260315(http.Handler):
     async def handle_request(self, request: Request) -> Response:
-        with key_value.open_default() as a:
-            a.set("test", bytes("hello world!", "utf-8"))
-            print(a.get_keys())
-            print(a.exists("test"))
-            print(a.get("test"))
-            a.delete("test")
-            print(a.get_keys())
+        with await key_value.open_default() as a:
+            await a.set("test", bytes("hello world!", "utf-8"))
+            print(await a.get_keys())
+            print(await a.exists("test"))
+            print(await a.get("test"))
+            await a.delete("test")
+            print(await a.get_keys())
             
         return Response(
             200,
diff --git a/examples/spin-llm/app.py b/examples/spin-llm/app.py
@@ -3,10 +3,10 @@
 
 class WasiHttpHandler030Rc20260315(http.Handler):
     async def handle_request(self, request: Request) -> Response:
-        res = llm.infer("llama2-chat", "tell me a joke")
+        res = llm.infer("all-minilm-l6-v2", "tell me a joke")
         print(res.text)
         print(res.usage)
-        res = llm.infer_with_options("llama2-chat", "what is the theory of relativity", llm.InferencingParams(temperature=0.5))
+        res = llm.infer_with_options("all-minilm-l6-v2", "what is the theory of relativity", llm.InferencingParams(temperature=0.5))
         print(res.text)
         print(res.usage)
         return Response(
diff --git a/examples/spin-llm/spin.toml b/examples/spin-llm/spin.toml
@@ -13,6 +13,6 @@ component = "test"
 [component.test]
 source = "app.wasm"
 allowed_outbound_hosts = []
-ai_models = ["llama2-chat"]
+ai_models = ["all-minilm-l6-v2"]
 [component.test.build]
 command = "componentize-py -w spin:up/http-trigger@4.0.0 componentize app -o app.wasm"
diff --git a/examples/spin-outbound-mqtt/app.py b/examples/spin-outbound-mqtt/app.py
@@ -4,8 +4,8 @@
 
 class WasiHttpHandler030Rc20260315(http.Handler):
     async def handle_request(self, request: Request) -> Response:
-        with mqtt.open("mqtt://localhost:1883?client_id=client001", "user", "password", 30) as conn:
-            conn.publish("telemetry", bytes("Eureka!", "utf-8"), Qos.AT_LEAST_ONCE)
+        with await mqtt.open("mqtt://localhost:1883?client_id=client001", "user", "password", 30) as conn:
+            await conn.publish("telemetry", bytes("Eureka!", "utf-8"), Qos.AT_LEAST_ONCE)
 
         return Response(
             200,
diff --git a/examples/spin-postgres/app.py b/examples/spin-postgres/app.py
@@ -21,7 +21,7 @@ def format_rowset(rowset) -> str:
 
 class WasiHttpHandler030Rc20260315(http.Handler):
     async def handle_request(self, request: Request) -> Response:
-        with postgres.open("user=postgres dbname=spin_dev host=127.0.0.1") as db:
+        with await postgres.open("user=postgres dbname=spin_dev host=localhost sslmode=disable password=password") as db:
             rowset = db.query("SELECT * FROM test", [])
             result = format_rowset(rowset)
 
diff --git a/examples/spin-redis/app.py b/examples/spin-redis/app.py
@@ -3,8 +3,8 @@
 
 class WasiHttpHandler030Rc20260315(http.Handler):
     async def handle_request(self, request: Request) -> Response:
-        with redis.open("redis://localhost:6379") as db:
-            print(db.get("test"))
+        with await redis.open("redis://localhost:6379") as db:
+            print(await db.get("test"))
             
         return Response(
             200,
diff --git a/examples/spin-sqlite/app.py b/examples/spin-sqlite/app.py
@@ -4,7 +4,7 @@
 
 class WasiHttpHandler030Rc20260315(http.Handler):
     async def handle_request(self, request: Request) -> Response:
-        with sqlite.open_default() as db:
+        with await sqlite.open_default() as db:
             result = db.execute("SELECT * FROM todos WHERE id > (?);", [Value_Integer(1)])
             rows = result.rows
         
diff --git a/examples/spin-variables/app.py b/examples/spin-variables/app.py
@@ -3,7 +3,7 @@
 
 class WasiHttpHandler030Rc20260315(http.Handler):
     async def handle_request(self, request: Request) -> Response:
-        print(variables.get("message"))
+        print(await variables.get("message"))
         return Response(
             200,
             {"content-type": "text/plain"},
diff --git a/src/spin_sdk/key_value.py b/src/spin_sdk/key_value.py
@@ -20,7 +20,7 @@ async def open(name: str) -> Store:
     
     A `componentize_py_types.Err(spin_sdk.wit.imports.spin_key_value_key_value_3_0_0.Error_Other(str))` will be raised if some implementation specific error has occured (e.g I/O)
     """
-    return Store.open(name)
+    return await Store.open(name)
 
 async def open_default() -> Store:
     """
@@ -35,4 +35,4 @@ async def open_default() -> Store:
 
     A `componentize_py_types.Err(spin_sdk.wit.imports.spin_key_value_key_value_3_0_0.Error_Other(str))` will be raised if some implementation specific error has occured (e.g I/O)
     """
-    return Store.open("default")
+    return await Store.open("default")
diff --git a/src/spin_sdk/mqtt.py b/src/spin_sdk/mqtt.py
@@ -15,4 +15,4 @@ async def open(address: str, username: str, password: str, keep_alive_interval_i
 
     A `componentize_py_types.Err(spin_sdk.wit.imports.spin_mqtt_mqtt_3_0_0.Error_Other(str))` when some other error occurs.
     """
-    return Connection.open(address, username, password, keep_alive_interval_in_secs)
+    return await Connection.open(address, username, password, keep_alive_interval_in_secs)
diff --git a/src/spin_sdk/postgres.py b/src/spin_sdk/postgres.py
@@ -12,4 +12,4 @@ async def open(connection_string: str) -> Connection:
     
     A `componentize_py_types.Err(Error_Other(str))` when some other error occurs.
     """
-    return Connection.open(connection_string)
+    return await Connection.open_async(connection_string)
diff --git a/src/spin_sdk/redis.py b/src/spin_sdk/redis.py
@@ -14,4 +14,4 @@ async def open(connection_string: str) -> Connection:
     
     A `componentize_py_types.Err(spin_sdk.wit.imports.spin_redis_redis_3_0_0.Error_Other(str))` when some other error occurs.
     """
-    return Connection.open(connection_string)
+    return await Connection.open(connection_string)
diff --git a/src/spin_sdk/sqlite.py b/src/spin_sdk/sqlite.py
@@ -18,7 +18,7 @@ async def open(name: str) -> Connection:
     
     A `componentize_py_types.Err(spin_sdk.wit.imports.spin_sqlite_sqlite_3_1_0.Error_Io(str))` will be raised when implementation-specific error occured (e.g. I/O)
     """
-    return Connection.open(name)
+    return await Connection.open_async(name)
 
 async def open_default() -> Connection:
     """Open the default store.
@@ -27,4 +27,4 @@ async def open_default() -> Connection:
 
     A `componentize_py_types.Err(spin_sdk.wit.imports.spin_sqlite_sqlite_3_1_0.Error_Io(str))` will be raised when implementation-specific error occured (e.g. I/O)
     """
-    return Connection.open("default")
+    return await Connection.open_async("default")
diff --git a/src/spin_sdk/variables.py b/src/spin_sdk/variables.py
@@ -6,4 +6,4 @@ async def get(key: str):
     """
     Gets the value of the given key
     """
-    return variables.get(key)
+    return await variables.get(key)
