add examples

examples/logging/magentic_async_stream_logging.py

@@ -0,0 +1,25 @@
+import asyncio
+
+import openai
+from magentic import AsyncStreamedStr, prompt
+
+from log10.load import log10, log10_session
+
+
+log10(openai)
+
+
+@prompt("Tell me a 200-word story about {topic}")
+async def tell_story(topic: str) -> AsyncStreamedStr:
+    ...
+
+
+async def main():
+    with log10_session(tags=["async_tag"]):
+        output = await tell_story("Europe.")
+        async for chunk in output:
+            print(chunk, end="", flush=True)
+
+
+# Python 3.7+
+asyncio.run(main())

examples/logging/openai_async_logging.py

@@ -0,0 +1,22 @@
+import asyncio
+
+import openai
+from openai import AsyncOpenAI
+
+from log10.load import log10
+
+
+log10(openai)
+
+client = AsyncOpenAI()
+
+
+async def main():
+    completion = await client.chat.completions.create(
+        model="gpt-4",
+        messages=[{"role": "user", "content": "Say this is a test"}],
+    )
+    print(completion.choices[0].message.content)
+
+
+asyncio.run(main())

examples/logging/openai_async_stream_logging.py

@@ -0,0 +1,24 @@
+import asyncio
+
+import openai
+from openai import AsyncOpenAI
+
+from log10.load import log10
+
+
+log10(openai)
+
+client = AsyncOpenAI()
+
+
+async def main():
+    stream = await client.chat.completions.create(
+        model="gpt-4",
+        messages=[{"role": "user", "content": "Count to 50."}],
+        stream=True,
+    )
+    async for chunk in stream:
+        print(chunk.choices[0].delta.content or "", end="", flush=True)
+
+
+asyncio.run(main())