hansthen · May 25, 2025 17:14 · May 25, 2025
diff --git a/gistfile1.txt b/gistfile1.txt
@@ -0,0 +1,54 @@
+import aiohttp
+import asyncio
+from pipe import Pipe
+import json
+import jq
+
+
+api_key="<your key>"
+
+async def schedule(interval):
+    while True:
+        yield
+        await asyncio.sleep(interval)
+
+@Pipe
+async def iss(stream):
+    async with aiohttp.ClientSession() as session:
+        async for _ in stream:
+            async with session.get("https://api.wheretheiss.at/v1/satellites/25544") as response:
+                data = await response.json()
+                yield data
+
+@Pipe
+async def reverse_geocode(stream, api_key):
+    async with aiohttp.ClientSession() as session:
+        async for item in stream:
+            url = (
+                "https://maps.googleapis.com/maps/api/geocode/json?"
+                "latlng={latitude},{longitude}&key=" + api_key
+            )
+            async with session.get(url.format(**item)) as response:
+                data = await response.json()
+                item["reverse"] = data
+                yield item
+
+@Pipe
+async def jq_transform(stream, program):
+    p = jq.compile(program)
+    async for item in stream:
+        for s in p.input(item).all():
+            yield s
+
+@Pipe
+async def display(stream):
+    async for item in stream:
+        print(json.dumps(item))
+
+
+select_address = """
+[.reverse.results[] | select(.types != ["plus_code"])] | first
+
+"""
+asyncio.run(schedule(10) | iss | reverse_geocode(api_key) |
+    jq_transform(select_address) | display)
No results found