Updates Python Workers examples to use new Python SDK API

src/content/docs/d1/examples/query-d1-from-python-workers.mdx

@@ -81,7 +81,7 @@ The value of `binding` is how you will refer to your database from within your W
 To create a Python Worker, create an empty file at `src/entry.py`, matching the value of `main` in your Wrangler file with the contents below:
 
 ```python
-from js import Response
+from workers import Response
 
 async def on_fetch(request, env):
     # Do anything else you'd like on request here!

src/content/docs/workers/examples/103-early-hints.mdx

@@ -111,7 +111,7 @@ export default {
 
 ```py
 import re
-from js import Response, Headers
+from workers import Response
 
 CSS = "body { color: red; }"
 HTML = """
@@ -129,11 +129,11 @@ HTML = """
 """
 def on_fetch(request):
     if re.search("test.css", request.url):
-        headers = Headers.new({"content-type": "text/css"}.items())
-        return Response.new(CSS, headers=headers)
+        headers = {"content-type": "text/css"}
+        return Response(CSS, headers=headers)
     else:
-        headers = Headers.new({"content-type": "text/html","link": "</test.css>; rel=preload; as=style"}.items())
-        return Response.new(HTML, headers=headers)
+        headers = {"content-type": "text/html","link": "</test.css>; rel=preload; as=style"}
+        return Response(HTML, headers=headers)
 ```
 
 </TabItem> </Tabs>

src/content/docs/workers/examples/ab-testing.mdx

@@ -100,7 +100,7 @@ export default {
 ```py
 import random
 from urllib.parse import urlparse, urlunparse
-from js import Response, Headers, fetch
+from workers import Response, fetch
 
 NAME = "myExampleWorkersABTest"
 
@@ -132,8 +132,7 @@ async def on_fetch(request):
         res = await fetch(urlunparse(url))
         headers = dict(res.headers)
         headers["Set-Cookie"] = f'{NAME}={group}; path=/'
-        headers  = Headers.new(headers.items())
-        return Response.new(res.body, headers=headers)
+        return Response(res.body, headers=headers)
 
     return fetch(urlunparse(url))
 ```

src/content/docs/workers/examples/accessing-the-cloudflare-object.mdx

@@ -60,13 +60,14 @@ export default {
 
 ```py
 import json
-from js import Response, Headers, JSON
+from workers import Response
+from js import JSON
 
 def on_fetch(request):
     error = json.dumps({ "error": "The `cf` object is not available inside the preview." })
     data = request.cf if request.cf is not None else error
-    headers = Headers.new({"content-type":"application/json"}.items())
-    return Response.new(JSON.stringify(data, None, 2), headers=headers)
+    headers = {"content-type":"application/json"}
+    return Response(JSON.stringify(data, None, 2), headers=headers)
 ```
 
 </TabItem> </Tabs>

src/content/docs/workers/examples/aggregate-requests.mdx

@@ -61,19 +61,21 @@ export default {
 </TabItem> <TabItem label="Python" icon="seti:python">
 
 ```py
-from js import Response, fetch, Headers, JSON, Promise
+from workers import Response, fetch
+import asyncio
+import json
 
 async def on_fetch(request):
     # some_host is set up to return JSON responses
     some_host = "https://jsonplaceholder.typicode.com"
     url1 = some_host + "/todos/1"
     url2 = some_host + "/todos/2"
 
-    responses = await Promise.all([fetch(url1), fetch(url2)])
-    results = await Promise.all(map(lambda r: r.json(), responses))
+    responses = await asyncio.gather(fetch(url1), fetch(url2))
+    results = await asyncio.gather(*(r.json() for r in responses))
 
-    headers = Headers.new({"content-type": "application/json;charset=UTF-8"}.items())
-    return Response.new(JSON.stringify(results), headers=headers)
+    headers = {"content-type": "application/json;charset=UTF-8"}
+    return Response.json(results, headers=headers)
 ```
 
 </TabItem> </Tabs>

src/content/docs/workers/examples/alter-headers.mdx

@@ -80,28 +80,27 @@ export default {
 </TabItem> <TabItem label="Python" icon="seti:python">
 
 ```py
-from js import Response, fetch
+from workers import Response, fetch
 
 async def on_fetch(request):
     response = await fetch("https://example.com")
 
-    # Clone the response so that it's no longer immutable
-    new_response = Response.new(response.body, response)
+    # Grab the response headers so they can be modified
+    new_headers = response.headers
 
     # Add a custom header with a value
-    new_response.headers.append(
-      "x-workers-hello",
-      "Hello from Cloudflare Workers"
-    )
-
+    new_headers["x-workers-hello"] = "Hello from Cloudflare Workers"
+
     # Delete headers
-    new_response.headers.delete("x-header-to-delete")
-    new_response.headers.delete("x-header2-to-delete")
+    if "x-header-to-delete" in new_headers:
+        del new_headers["x-header-to-delete"]
+    if "x-header2-to-delete" in new_headers:
+        del new_headers["x-header2-to-delete"]
 
     # Adjust the value for an existing header
-    new_response.headers.set("x-header-to-change", "NewValue")
+    new_headers["x-header-to-change"] = "NewValue"
 
-    return new_response
+    return Response(response.body, headers=new_headers)
 ```
 
 </TabItem> </Tabs>

src/content/docs/workers/examples/auth-with-headers.mdx

@@ -79,20 +79,20 @@ export default {
 </TabItem> <TabItem label="Python" icon="seti:python">
 
 ```py
-from js import Response, fetch
+from workers import Response, fetch
 
 async def on_fetch(request):
     PRESHARED_AUTH_HEADER_KEY = "X-Custom-PSK"
     PRESHARED_AUTH_HEADER_VALUE = "mypresharedkey"
 
-    psk = request.headers.get(PRESHARED_AUTH_HEADER_KEY)
+    psk = request.headers[PRESHARED_AUTH_HEADER_KEY]
 
     if psk == PRESHARED_AUTH_HEADER_VALUE:
       # Correct preshared header key supplied. Fetch request from origin.
       return fetch(request)
 
     # Incorrect key supplied. Reject the request.
-    return Response.new("Sorry, you have supplied an invalid key.", status=403);
+    return Response("Sorry, you have supplied an invalid key.", status=403)
 ```
 
 </TabItem> </Tabs>

src/content/docs/workers/examples/block-on-tls.mdx

@@ -72,12 +72,12 @@ export default {
 </TabItem> <TabItem label="Python" icon="seti:python">
 
 ```py
-from js import Response, fetch
+from workers import Response, fetch
 
 async def on_fetch(request):
     tls_version = request.cf.tlsVersion
     if tls_version not in ("TLSv1.2", "TLSv1.3"):
-        return Response.new("Please use TLS version 1.2 or higher.", status=403)
+        return Response("Please use TLS version 1.2 or higher.", status=403)
     return fetch(request)
 ```
 

src/content/docs/workers/examples/bulk-redirects.mdx

@@ -76,7 +76,8 @@ export default {
 </TabItem> <TabItem label="Python" icon="seti:python">
 
 ```py
-from js import Response, fetch, URL
+from workers import Response, fetch
+from urllib.parse import urlparse
 
 async def on_fetch(request):
     external_hostname = "examples.cloudflareworkers.com"
@@ -88,8 +89,8 @@ async def on_fetch(request):
       "/bulk4": "https://google.com",
       }
 
-    url = URL.new(request.url)
-    location = redirect_map.get(url.pathname, None)
+    url = urlparse(request.url)
+    location = redirect_map.get(url.path, None)
 
     if location:
         return Response.redirect(location, 301)

src/content/docs/workers/examples/conditional-response.mdx

@@ -120,37 +120,38 @@ export default {
 
 ```py
 import re
-from js import Response, URL, fetch
+from workers import Response
+from urllib.parse import urlparse
 
 async def on_fetch(request):
     blocked_hostnames = ["nope.mywebsite.com", "bye.website.com"]
-    url = URL.new(request.url)
+    url = urlparse(request.url)
 
     # Block on hostname
     if url.hostname in blocked_hostnames:
-        return Response.new("Blocked Host", status=403)
+        return Response("Blocked Host", status=403)
 
     # On paths ending in .doc or .xml
-    if re.search(r'\.(doc|xml)$', url.pathname):
-        return Response.new("Blocked Extension", status=403)
+    if re.search(r'\.(doc|xml)$', url.path):
+        return Response("Blocked Extension", status=403)
 
     # On HTTP method
     if "POST" in request.method:
-        return Response.new("Response for POST")
+        return Response("Response for POST")
 
     # On User Agent
     user_agent = request.headers["User-Agent"] or ""
     if "bot" in user_agent:
-        return Response.new("Block User Agent containing bot", status=403)
+        return Response("Block User Agent containing bot", status=403)
 
     # On Client's IP address
     client_ip = request.headers["CF-Connecting-IP"]
     if client_ip == "1.2.3.4":
-        return Response.new("Block the IP 1.2.3.4", status=403)
+        return Response("Block the IP 1.2.3.4", status=403)
 
     # On ASN
     if request.cf and request.cf.asn == 64512:
-        return Response.new("Block the ASN 64512 response")
+        return Response("Block the ASN 64512 response")
 
     # On Device Type
     # Requires Enterprise "CF-Device-Type Header" zone setting or

src/content/docs/workers/examples/country-code-redirect.mdx

@@ -82,7 +82,7 @@ export default {
 </TabItem> <TabItem label="Python" icon="seti:python">
 
 ```py
-from js import Response, fetch
+from workers import Response, fetch
 
 async def on_fetch(request):
     countries = {

src/content/docs/workers/examples/extract-cookie-value.mdx

@@ -58,7 +58,7 @@ export default {
 
 ```py
 from http.cookies import SimpleCookie
-from js import Response
+from workers import Response
 
 async def on_fetch(request):
     # Name of the cookie
@@ -68,9 +68,9 @@ async def on_fetch(request):
 
     if cookie_name in cookies:
         # Respond with cookie value
-        return Response.new(cookies[cookie_name].value)
+        return Response(cookies[cookie_name].value)
 
-    return Response.new("No cookie with name: " + cookie_name)
+    return Response("No cookie with name: " + cookie_name)
 ```
 
 </TabItem> </Tabs>

src/content/docs/workers/examples/fetch-json.mdx

@@ -74,7 +74,8 @@ export default {
 </TabItem> <TabItem label="Python" icon="seti:python">
 
 ```py
-from js import Response, fetch, Headers, JSON
+from workers import Response, fetch
+import json
 
 async def on_fetch(request):
     url = "https://jsonplaceholder.typicode.com/todos/1"
@@ -85,15 +86,15 @@ async def on_fetch(request):
         content_type = headers["content-type"] or ""
 
         if "application/json" in content_type:
-            return (content_type, JSON.stringify(await response.json()))
+            return (content_type, json.dumps(await response.json()))
         return (content_type, await response.text())
 
     response = await fetch(url)
     content_type, result = await gather_response(response)
 
 
-    headers = Headers.new({"content-type": content_type}.items())
-    return Response.new(result, headers=headers)
+    headers = {"content-type": content_type}
+    return Response(result, headers=headers)
 ```
 
 </TabItem> </Tabs>

src/content/docs/workers/examples/geolocation-app-weather.mdx

@@ -123,7 +123,7 @@ export default {
 </TabItem> <TabItem label="Python" icon="seti:python">
 
 ```py
-from js import Response, Headers, fetch
+from workers import Response, fetch
 
 async def on_fetch(request):
     endpoint = "https://api.waqi.info/feed/geo:"
@@ -140,11 +140,11 @@ async def on_fetch(request):
 
     html_content += "<p>This is a demo using Workers geolocation data. </p>"
     html_content += f"You are located at: {latitude},{longitude}.</p>"
-    html_content += f"<p>Based off sensor data from <a href='{content.data.city.url}'>{content.data.city.name}</a>:</p>"
-    html_content += f"<p>The AQI level is: {content.data.aqi}.</p>"
-    html_content += f"<p>The N02 level is: {content.data.iaqi.no2.v}.</p>"
-    html_content += f"<p>The O3 level is: {content.data.iaqi.o3.v}.</p>"
-    html_content += f"<p>The temperature is: {content.data.iaqi.t.v}°C.</p>"
+    html_content += f"<p>Based off sensor data from <a href='{content['data']['city']['url']}'>{content['data']['city']['name']}</a>:</p>"
+    html_content += f"<p>The AQI level is: {content['data']['aqi']}.</p>"
+    html_content += f"<p>The N02 level is: {content['data']['iaqi']['no2']['v']}.</p>"
+    html_content += f"<p>The O3 level is: {content['data']['iaqi']['o3']['v']}.</p>"
+    html_content += f"<p>The temperature is: {content['data']['iaqi']['t']['v']}°C.</p>"
 
     html = f"""
     <!DOCTYPE html>
@@ -159,8 +159,8 @@ async def on_fetch(request):
       </body>
     """
 
-    headers = Headers.new({"content-type": "text/html;charset=UTF-8"}.items())
-    return Response.new(html, headers=headers)
+    headers = {"content-type": "text/html;charset=UTF-8"}
+    return Response(html, headers=headers)
 ```
 
 </TabItem> </Tabs>

src/content/docs/workers/examples/geolocation-hello-world.mdx

@@ -103,7 +103,7 @@ export default {
 </TabItem> <TabItem label="Python" icon="seti:python">
 
 ```py
-from js import Response, Headers
+from workers import Response
 
 async def on_fetch(request):
     html_content = ""
@@ -133,8 +133,8 @@ async def on_fetch(request):
       </body>
     """
 
-    headers = Headers.new({"content-type": "text/html;charset=UTF-8"}.items())
-    return Response.new(html, headers=headers)
+    headers = {"content-type": "text/html;charset=UTF-8"}
+    return Response(html, headers=headers)
 ```
 
 </TabItem> </Tabs>

src/content/docs/workers/examples/hot-link-protection.mdx

@@ -82,7 +82,8 @@ export default {
 </TabItem> <TabItem label="Python" icon="seti:python">
 
 ```py
-from js import Response, URL, fetch
+from workers import Response, fetch
+from urllib.parse import urlparse
 
 async def on_fetch(request):
     homepage_url = "https://tutorial.cloudflareworkers.com/"
@@ -97,7 +98,7 @@ async def on_fetch(request):
 
     if referer and content_type.startswith(protected_type):
         # If the hostnames don't match, it's a hotlink
-        if URL.new(referer).hostname != URL.new(request.url).hostname:
+        if urlparse(referer).hostname != urlparse(request.url).hostname:
             # Redirect the user to your website
             return Response.redirect(homepage_url, 302)
 

src/content/docs/workers/examples/logging-headers.mdx

@@ -45,11 +45,11 @@ export default {
 </TabItem> <TabItem label="Python" icon="seti:python">
 
 ```py
-from js import Response
+from workers import Response
 
 async def on_fetch(request):
     print(dict(request.headers))
-    return Response.new('Hello world')
+    return Response('Hello world')
 ```
 
 </TabItem> <TabItem label="Rust" icon="seti:rust">