事件队列与批处理

from langfuse import get_client
 
# access the client directly
 
langfuse = get_client()
 
# Flush all pending observations
 
langfuse.flush()
 

from langfuse import get_client
 
langfuse = get_client()
 
langfuse.shutdown()

import { NodeSDK } from "@opentelemetry/sdk-node";
import { LangfuseSpanProcessor } from "@langfuse/otel";
 
// Export the processor to be able to flush it
export const langfuseSpanProcessor = new LangfuseSpanProcessor();
 
const sdk = new NodeSDK({
  spanProcessors: [langfuseSpanProcessor],
});
 
sdk.start();

import { langfuseSpanProcessor } from "./instrumentation";
 
export async function handler(event, context) {
  // ... your application logic ...
 
  // Flush before exiting
  await langfuseSpanProcessor.forceFlush();
}

from langfuse import get_client
 
# access the client directly
langfuse = get_client()
 
# Flush all pending observations
langfuse.flush()

from langfuse import get_client
 
langfuse = get_client()
 
langfuse.flush()
 
# access the client directly
langfuse_handler.client.flush()
 

await langfuseHandler.flushAsync();

await langfuseHandler.shutdownAsync();