#!/usr/bin/env bash
set -euo pipefail

ls -la /Langfuse/langfuse
cd /Langfuse/langfuse
git remote -v
ls docker-compose.yml .env.prod.example

#!/usr/bin/env bash
set -euo pipefail

mkdir -p /Langfuse
cd /Langfuse
git clone https://github.com/langfuse/langfuse.git
cd langfuse

#!/usr/bin/env bash
set -euo pipefail

openssl rand -hex 32   # NEXTAUTH_SECRET
openssl rand -hex 16   # SALT
openssl rand -hex 32   # ENCRYPTION_KEY，必须是 64 位十六进制
openssl rand -hex 16   # POSTGRES_PASSWORD
openssl rand -hex 12   # CLICKHOUSE_PASSWORD
openssl rand -hex 16   # REDIS_AUTH
openssl rand -hex 16   # MINIO_ROOT_PASSWORD

NEXTAUTH_URL=http://192.168.110.207:3000
NEXTAUTH_SECRET=请替换
SALT=请替换
ENCRYPTION_KEY=请替换

POSTGRES_USER=postgres
POSTGRES_PASSWORD=请替换
POSTGRES_DB=postgres
DATABASE_URL=postgresql://postgres:请替换@postgres:5432/postgres

CLICKHOUSE_USER=clickhouse
CLICKHOUSE_PASSWORD=请替换

REDIS_AUTH=请替换

MINIO_ROOT_USER=minio
MINIO_ROOT_PASSWORD=请替换
LANGFUSE_S3_EVENT_UPLOAD_ACCESS_KEY_ID=minio
LANGFUSE_S3_EVENT_UPLOAD_SECRET_ACCESS_KEY=请替换
LANGFUSE_S3_MEDIA_UPLOAD_ACCESS_KEY_ID=minio
LANGFUSE_S3_MEDIA_UPLOAD_SECRET_ACCESS_KEY=请替换
LANGFUSE_S3_BATCH_EXPORT_ACCESS_KEY_ID=minio
LANGFUSE_S3_BATCH_EXPORT_SECRET_ACCESS_KEY=请替换

TELEMETRY_ENABLED=false

LANGFUSE_INIT_ORG_ID=dckj
LANGFUSE_INIT_ORG_NAME=DCKJ
LANGFUSE_INIT_PROJECT_ID=default
LANGFUSE_INIT_PROJECT_NAME=default
LANGFUSE_INIT_USER_EMAIL=admin@example.com
LANGFUSE_INIT_USER_NAME=admin
LANGFUSE_INIT_USER_PASSWORD=Langfuse123456

docker.io/langfuse/langfuse:4
docker.io/langfuse/langfuse-worker:4
docker.io/postgres:17
docker.io/redis:7
docker.io/clickhouse/clickhouse-server:25.12
cgr.dev/chainguard/minio

Get "https://registry-1.docker.io/v2/": dial tcp ...:443: i/o timeout

#!/usr/bin/env bash
set -euo pipefail

# Redis
docker pull docker.m.daocloud.io/library/redis:7
docker tag docker.m.daocloud.io/library/redis:7 redis:7
docker tag redis:7 docker.io/redis:7

# Langfuse Worker
docker pull docker.m.daocloud.io/langfuse/langfuse-worker:4
docker tag docker.m.daocloud.io/langfuse/langfuse-worker:4 langfuse/langfuse-worker:4
docker tag langfuse/langfuse-worker:4 docker.io/langfuse/langfuse-worker:4

# ClickHouse
docker pull docker.m.daocloud.io/clickhouse/clickhouse-server:25.12
docker tag docker.m.daocloud.io/clickhouse/clickhouse-server:25.12 clickhouse/clickhouse-server:25.12
docker tag clickhouse/clickhouse-server:25.12 docker.io/clickhouse/clickhouse-server:25.12

# Web / Postgres 若还没有，同样处理
docker pull docker.m.daocloud.io/langfuse/langfuse:4
docker tag docker.m.daocloud.io/langfuse/langfuse:4 langfuse/langfuse:4
docker tag langfuse/langfuse:4 docker.io/langfuse/langfuse:4

docker pull docker.m.daocloud.io/library/postgres:17
docker tag docker.m.daocloud.io/library/postgres:17 postgres:17
docker tag postgres:17 docker.io/postgres:17

#!/usr/bin/env bash
set -euo pipefail

cd /Langfuse/langfuse
docker compose -p langfuse up -d --remove-orphans

#!/usr/bin/env bash
set -euo pipefail

systemd-run --unit=langfuse-compose-up --collect \
  /bin/bash -c 'cd /Langfuse/langfuse && docker compose -p langfuse up -d --remove-orphans'

#!/usr/bin/env bash
set -euo pipefail

systemctl status langfuse-compose-up --no-pager
journalctl -u langfuse-compose-up -f

#!/usr/bin/env bash
set -euo pipefail

cd /Langfuse/langfuse
docker compose -p langfuse ps

#!/usr/bin/env bash
set -euo pipefail

curl -sS http://127.0.0.1:3000/api/public/health
curl -sS -o /dev/null -w "%{http_code}\n" http://192.168.110.207:3000

{"status":"OK","version":"4.12.0"}
200

http://192.168.110.207:3000

Invalid environment variables

#!/usr/bin/env bash
set -euo pipefail

cd /Langfuse/langfuse
docker compose -p langfuse up -d langfuse-web

LANGFUSE_INIT_ORG_ID is not set but other LANGFUSE_INIT_* variables are configured.
The following variables will be ignored: ... LANGFUSE_INIT_USER_EMAIL ...

#!/usr/bin/env bash
set -euo pipefail

cd /Langfuse/langfuse
docker compose -p langfuse up -d

#!/usr/bin/env bash
set -euo pipefail

cd /Langfuse/langfuse
docker compose -p langfuse stop

#!/usr/bin/env bash
set -euo pipefail

docker logs -f langfuse-langfuse-web-1
docker logs -f langfuse-langfuse-worker-1

#!/usr/bin/env bash
set -euo pipefail

cd /Langfuse/langfuse
docker compose -p langfuse up -d --force-recreate langfuse-web

http://192.168.110.207:3000

admin@example.com
Langfuse123456

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
"""Langfuse 专题 · 步骤 0：确认 Langfuse / Dify 容器与健康检查。"""
from __future__ import annotations

import sys

import _bootstrap  # noqa: F401
import _config as C
from dify_api import Dify


def main() -> int:
    d = Dify(C.DIFY_EMAIL, C.DIFY_PASSWORD)
    try:
        print("=== 容器 ===")
        out, err = d.sh(
            "docker ps --format 'table {{.Names}}\t{{.Status}}' | grep -E 'langfuse|docker-api-1|docker-worker-1'"
        )
        print(out or err)

        print("\n=== Langfuse health ===")
        out, err = d.sh("curl -s %s" % C.LANGFUSE_HEALTH)
        print(out or err)

        for ctr in (C.DIFY_API_CTR, C.DIFY_WORKER):
            print("\n=== %s -> Langfuse ===" % ctr)
            out, err = d.sh(
                "docker exec %s curl -s -m 8 %s" % (ctr, C.LANGFUSE_HEALTH)
            )
            print(out or err)
        return 0
    finally:
        d.close()


if __name__ == "__main__":
    sys.exit(main())

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
"""Langfuse 专题 · 步骤 5 · 修改后：给 langfuse_trace.py 补 Observation UUID，重启 worker。"""
from __future__ import annotations

import sys
import time

import _bootstrap  # noqa: F401
import _config as C
import _plugin_util as PU
from dify_api import Dify

LF_TRACE_PATH = (
    "/app/api/.venv/lib/python3.12/site-packages/dify_trace_langfuse/langfuse_trace.py"
)


def patch_container(d: Dify, container: str) -> None:
    content = PU.container_read(d, container, LF_TRACE_PATH)
    if PU.LF_TRACE_MARKER in content:
        print(container, "already patched")
        return
    new_content = PU.apply_langfuse_trace_patch(content)
    PU.container_write(d, container, LF_TRACE_PATH, new_content)
    out, err = d.sh(
        "docker exec %s python -m py_compile %s" % (container, LF_TRACE_PATH)
    )
    print(container, "py_compile:", out or err or "ok")


def main() -> int:
    d = Dify(C.DIFY_EMAIL, C.DIFY_PASSWORD)
    try:
        d.login()
        for ctr in (C.DIFY_WORKER, C.DIFY_API_CTR):
            patch_container(d, ctr)

        print("\n=== restart docker-worker-1 ===")
        out, err = d.sh("docker restart %s" % C.DIFY_WORKER, t=120)
        print(out or err)

        for i in range(15):
            out, _ = d.sh("docker logs --since 30s %s 2>&1 | tail -5" % C.DIFY_WORKER)
            if "ready" in (out or "").lower():
                print("worker ready")
                break
            time.sleep(2)
        else:
            print("[WARN] 未在日志中看到 celery ready，请手动 docker logs -f", C.DIFY_WORKER)

        for ctr in (C.DIFY_WORKER, C.DIFY_API_CTR):
            print(PU.grep_in_container(d, ctr, LF_TRACE_PATH, "auto-assign if missing"))
        return 0
    finally:
        d.close()


if __name__ == "__main__":
    sys.exit(main())

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
"""Langfuse 专题 · 步骤 5 · 修改前：确认 langfuse_trace.py 是否已打 Observation ID 补丁。"""
from __future__ import annotations

import sys

import _bootstrap  # noqa: F401
import _config as C
import _plugin_util as PU
from dify_api import Dify

LF_TRACE_PATH = (
    "/app/api/.venv/lib/python3.12/site-packages/dify_trace_langfuse/langfuse_trace.py"
)


def main() -> int:
    d = Dify(C.DIFY_EMAIL, C.DIFY_PASSWORD)
    try:
        for ctr in (C.DIFY_WORKER, C.DIFY_API_CTR):
            print("\n=== %s ===" % ctr)
            out, err = d.sh("docker exec %s ls -l %s" % (ctr, LF_TRACE_PATH))
            print(out or err)
            grep = PU.grep_in_container(d, ctr, LF_TRACE_PATH, "auto-assign if missing")
            if grep.strip():
                print("[OK] 已打补丁:\n", grep)
            else:
                print("[WARN] 未打补丁 — 运行 Langfuse_01_打langfuse_trace补丁_修改后.py")
        return 0
    finally:
        d.close()


if __name__ == "__main__":
    sys.exit(main())

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
"""Langfuse 专题 · 步骤 3：POST trace-config + /trace 打开应用 Langfuse Tracing。"""
from __future__ import annotations

import sys

import _bootstrap  # noqa: F401
import _config as C
from dify_api import Dify, pp


def main() -> int:
    d = Dify(C.DIFY_EMAIL, C.DIFY_PASSWORD)
    try:
        ok, _, _ = d.login()
        print("login", ok)
        if not ok:
            return 1

        pp("current trace", d.get("/apps/%s/trace" % C.APP_ID))
        cfg = d.get("/apps/%s/trace-config?tracing_provider=langfuse" % C.APP_ID)
        pp("current config", cfg)

        body = {
            "tracing_provider": "langfuse",
            "tracing_config": {
                "public_key": C.LANGFUSE_PK,
                "secret_key": C.LANGFUSE_SK,
                "host": C.LANGFUSE_URL,
            },
        }
        if (cfg.get("json") or {}).get("has_not_configured"):
            r = d.post("/apps/%s/trace-config" % C.APP_ID, body=body)
            pp("create trace-config", r)
        else:
            r = d.req("PATCH", "/apps/%s/trace-config" % C.APP_ID, body=body)
            pp("update trace-config", r)
            if r.get("code") not in ("200", "201"):
                r = d.post("/apps/%s/trace-config" % C.APP_ID, body=body)
                pp("create after failed patch", r)

        r = d.post(
            "/apps/%s/trace" % C.APP_ID,
            body={"enabled": True, "tracing_provider": "langfuse"},
        )
        pp("enable tracing", r)

        pp("trace after", d.get("/apps/%s/trace" % C.APP_ID))
        pp("config after", d.get("/apps/%s/trace-config?tracing_provider=langfuse" % C.APP_ID))

        out, err = d.sh(
            "docker exec %s psql -U postgres -d dify -c "
            "\"SELECT id, name, tracing FROM apps WHERE id='%s';\""
            % (C.PG_CONTAINER, C.APP_ID)
        )
        print(out or err)
        return 0 if r.get("code") in ("200", "201") else 1
    finally:
        d.close()


if __name__ == "__main__":
    sys.exit(main())

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
"""Langfuse 专题 · 步骤 6：发验收对话 + 查 Celery ops_trace + Langfuse traces API。"""
from __future__ import annotations

import sys
import time

import _bootstrap  # noqa: F401
import _config as C
from dify_api import Dify


def main() -> int:
    d = Dify(C.DIFY_EMAIL, C.DIFY_PASSWORD)
    try:
        d.login()
        print("=== 1/3 发验收对话 ===")
        payload = {
            "inputs": {},
            "query": C.PROBE_QUERY_LANGFUSE,
            "response_mode": "streaming",
            "files": [],
            "conversation_id": "",
        }
        r = d.post(
            "/agent/%s/chat-messages" % C.AGENT_ID,
            body=payload,
            extra="-m 420 --max-time 420",
            t=450,
        )
        print("HTTP", r.get("code"))
        print((r.get("text") or "")[-800:])

        print("\n=== 2/3 worker ops_trace 日志 ===")
        time.sleep(5)
        out, err = d.sh(
            "docker logs --since 5m %s 2>&1 | grep ops_trace | tail -10" % C.DIFY_WORKER
        )
        print(out or err or "(无 ops_trace 行)")

        print("\n=== 3/3 Langfuse GET /api/public/traces ===")
        out2, err2 = d.sh(
            "curl -s -u '%s:%s' '%s/api/public/traces?limit=5'"
            % (C.LANGFUSE_PK, C.LANGFUSE_SK, C.LANGFUSE_URL)
        )
        print(out2 or err2)
        return 0 if r.get("code") == "200" else 1
    finally:
        d.close()


if __name__ == "__main__":
    sys.exit(main())