写入消息到终端和日志文件

r"""Returns a list of FunctionTool objects representing the functions in the toolkit. Returns: List[FunctionTool]: A list

返回字典表示，可JSON序列化

r"""Returns a list of FunctionTool objects representing the functions in the toolkit. Returns: List[FunctionTool]: A list of Func

关闭日志文件

创建特定角色的代理 Args: role: 角色名称 model_name: 模型名称 (gemini, openai, qwen) Returns: ChatAgent: 创建的角色代理

格式化数据为字符串 Args: data: 要格式化的数据 Returns: str: 格式化后的字符串

生成人类消息 Args: content: 消息内容 Returns: BaseMessage: 用户消息对象

记录消息 Args: message: 要记录的消息

从响应中解析JSON 尝试从响应文本中提取JSON数据，处理各种边缘情况 Args: response: 响应文本 Returns: Dict

Write content to the markdown file. Args: filename (str): Path to the markdown file. content (Dict[str, Any]): Content to wri

初始化.env文件如果不存在

初始化.env文件如果不存在

.envファイルが存在しない場合に初期化する

Initialize .env file if it doesn't exist

从队列中获取最新的日志行，如果队列为空则直接从文件读取 Args: max_lines: 最大返回行数 queue_source: 指定使用哪个队列，默认为LOG_QUEUE Returns: str: 日志内容

キューから最新のログ行を取得するか、キューが空の場合はファイルから直接読み取る 引数: max_lines: 返す最大行数 queue_source: 使用するキューを指定、デフォルトはLOG_QUEUE 戻り値: str: ログ内

Get the latest log lines from the queue, or read directly from the file if the queue is empty Args: max_lines: Maximum number of lines to

r"""Normalize a string. Args: input_str: The input string to normalize. remove_punct: Whether to remove punctuation.

Sanitize a value for logging.

添加或更新单个环境变量 Args: key: 环境变量名 value: 环境变量值 from_frontend: 是否来自前端配置，默认为True

単一の環境変数を追加または更新 引数: key: 環境変数名 value: 環境変数値 from_frontend: フロントエンド設定からかどうか、デフォルトはTrue

Add or update a single environment variable Args: key: Environment variable name value: Environment variable value from_f

Construct a specialized interview preparation assistant using OWL.

r"""Construct a society of agents based on the given question. Args: question (str): The task or question to be addressed by the society.

Display the conversation history in a structured format

Display metrics in a visually appealing format

Wrapper around run_society to ensure round limit is strictly enforced This implementation hijacks the step method to force termination after

Sanitize arguments for logging to avoid sensitive data.

从分析文本中确定投资评级 Args: analysis: 分析文本 Returns: str: 投资评级

使用代理处理数据分析请求 Args: prompt: 分析提示 data: 包含基本面数据和历史数据的数据 Returns: str: 分析结果文本

r"""Download the GAIA dataset.

Retrieve logs from the queue

判断环境变量是否与API相关 Args: key: 环境变量名 Returns: bool: 是否与API相关

環境変数がAPI関連かどうかを判断 引数: key: 環境変数名 戻り値: bool: API関連かどうか

Determine if an environment variable is API-related Args: key: Environment variable name Returns: bool: Whether it's API-rel

r"""Load the GAIA dataset. Args: force_download (bool, optional): Whether to force download the data.

加载环境变量并返回字典格式

加载环境变量并返回字典格式 Returns: dict: 环境变量字典，每个值为一个包含值和来源的元组 (value, source)

環境変数を読み込み、辞書形式で返す 戻り値: dict: 環境変数辞書、各値は値とソースを含むタプル（value, source）

Load environment variables and return as dictionary format Returns: dict: Environment variable dictionary, each value is a tuple containi

主函数

运行投资分析流程 Args: ticker: 股票代码 start_date: 开始日期 (YYYY-MM-DD) end_date: 结束日期 (YYYY-MM-DD) portfolio: 当前投资组合状

r"""Split a string based on a list of characters. Args: s (str): The string to split. char_list (Optional[List[str]],

r"""Async helper method to extract webpage content using crawl4ai.

计算财务趋势 Args: historical_data: 历史财务数据列表 Returns: Dict[str, Any]: 财务趋势数据

计算技术指标 Args: historical_data: 历史价格数据 Returns: Dict[str, Any]: 技术指标数据

创建辩论结果信号 Args: analysis_result: 分析结果 ticker: 股票代码 Returns: AnalysisSignal: 分

创建基本面分析信号 Args: analysis_result: 分析结果 stock_data: 股票数据 Returns: AnalysisSign

创建研究报告 Args: analysis_result: 分析结果 ticker: 股票代码 Returns: ResearchReport: 研究报

创建研究报告 Args: analysis_result: 分析结果 ticker: 股票代码 Returns: ResearchReport: 研究报

创建风险分析结果 Args: analysis_result: 分析结果 Returns: RiskAnalysis: 风险分析结果

创建情绪分析信号 Args: analysis_result: 分析结果 stock_data: 股票数据 Returns: AnalysisSigna

创建技术分析信号 Args: result: 分析结果 stock_data: 股票数据对象 Returns: AnalysisSignal: 技术分析

创建交易决策 Args: analysis_result: 分析结果 agent_signals: 分析师信号列表 Returns: TradingDe

创建估值分析信号 Args: analysis_result: 分析结果 stock_data: 股票数据 Returns: AnalysisSigna

从分析结果中提取投资建议 Args: analysis: 分析文本 Returns: Dict[str, Any]: 投资建议

r"""Extract the content of a webpage using crawl4ai.

r"""Generate and return a summary of the benchmark results.

获取股票的财务数据 Args: ticker: 股票代码 Returns: Dict[str, Any]: 财务数据

获取历史价格数据 Args: ticker: 股票代码 start_date: 开始日期 end_date: 结束日期 Returns:

获取历史财务数据 Args: ticker: 股票代码 num_quarters: 要获取的季度数量 Returns: List[Dict[str, A

获取最新价格 Args: historical_data: 历史数据 Returns: float: 最新价格

获取股票相关的新闻数据 Args: ticker: 股票代码 num_of_news: 获取的新闻数量 Returns: Dict[str, Any]:

r"""Initialize assistant and user agents with their system messages. Args: init_assistant_sys_msg (BaseMessage): Assistant agent'

r"""Judge whether the given URL is a webpage.

r"""Prepare the task by validating and enriching its data.

使用代理处理数据并获取结果 Args: prompt: 提示信息 data: 要处理的数据 Returns: Dict[str, Any]: 处理结果

使用代理处理数据分析请求 Args: prompt: 分析提示 data: 包含各类分析结果的数据 Returns: Dict[str, Any]: 分

使用代理处理数据分析请求 Args: prompt: 分析提示 data: 包含各种分析数据 Returns: Dict[str, Any]: 分析结果

使用代理处理数据分析请求 Args: prompt: 分析提示 data: 包含基本面数据和历史数据的数据 Returns: Dict[str, Any

使用代理处理数据分析请求 Args: prompt: 分析提示 data: 包含风险评估相关数据 Returns: Dict[str, Any]: 分析

使用代理处理数据分析请求 Args: prompt: 分析提示 data: 包含技术指标和历史数据的数据 Returns: Dict[str, Any]

使用代理处理数据分析请求 Args: prompt: 分析提示 data: 包含新闻数据的字典 Returns: Dict[str, Any]: 分析结

使用代理处理数据分析请求 Args: prompt: 分析提示 data: 包含基本面数据和历史数据的数据 Returns: Dict[str, Any

使用代理处理数据分析请求 Args: prompt: 分析提示 data: 包含各类分析结果的数据 Returns: Dict[str, Any]: 分

使用代理处理数据分析请求 Args: prompt: 分析提示 data: 包含多空研究报告的数据 Returns: Dict[str, Any]: 分

添加或更新单个环境变量

Analyze chat history and extract tool call information.

Analyze chat history and extract tool call information.

计算技术指标 Args: df: 股票历史数据DataFrame Returns: Dict[str, Any]: 技术指标

清空日志文件内容

ログファイルの内容をクリア

Clear log file content