mirror of
https://github.com/langflow-ai/langflow.git
synced 2026-07-24 19:04:04 +08:00
28 lines
733 B
Python
28 lines
733 B
Python
import os
|
|
|
|
import requests
|
|
|
|
base = os.environ.get("LANGFLOW_URL") or os.environ.get("LANGFLOW_SERVER_URL", "")
|
|
api_key = os.environ.get("LANGFLOW_API_KEY", "")
|
|
|
|
# `/logs-stream` is an SSE endpoint. For doc example stability, only read a small
|
|
# number of events, then close the connection.
|
|
url = f"{base}/logs-stream"
|
|
headers = {"accept": "text/event-stream", "x-api-key": api_key}
|
|
|
|
response = requests.get(url, headers=headers, stream=True, timeout=30)
|
|
response.raise_for_status()
|
|
|
|
events_read = 0
|
|
chunks: list[str] = []
|
|
for line in response.iter_lines(decode_unicode=True):
|
|
if line:
|
|
chunks.append(line)
|
|
events_read += 1
|
|
if events_read >= 3:
|
|
break
|
|
|
|
response.close()
|
|
|
|
print("\n".join(chunks))
|