Method execute

src/infrastructure/executors/python_executor.py:71–115

执行 Python 代码节点 参数： node: 节点实体 inputs: 输入数据（来自前驱节点） context: 执行上下文 返回： 代码执行后 result 变量的值

(self, node: Node, inputs: dict[str, Any], context: dict[str, Any])

    }

    async def execute(self, node: Node, inputs: dict[str, Any], context: dict[str, Any]) -> Any:
        """执行 Python 代码节点

        参数：
            node: 节点实体
            inputs: 输入数据（来自前驱节点）
            context: 执行上下文

        返回：
            代码执行后 result 变量的值
        """
        code = node.config.get("code", "")

        if not code:
            raise DomainError("Python 节点缺少代码")

        # 检查禁止的模块和操作
        code_lower = code.lower()
        for forbidden in self.FORBIDDEN_KEYWORDS:
            if forbidden.lower() in code_lower:
                raise DomainError(f"Python 代码包含被禁止的操作: {forbidden}")

        # 准备执行环境
        exec_context = {
            "__builtins__": self.SAFE_BUILTINS,
        }

        # 将输入映射为 input1, input2, ...
        for i, (_key, value) in enumerate(inputs.items(), 1):
            exec_context[f"input{i}"] = value

        # 添加上下文变量
        exec_context["context"] = context

        try:
            # 执行代码
            exec(code, exec_context)

            # 返回结果（假设代码中有 result 变量赋值）
            return exec_context.get("result")

        except SyntaxError as e:
            raise DomainError(f"Python 代码执行失败: 语法错误 - {str(e)}") from e
        except Exception as e:
            raise DomainError(f"Python 代码执行失败: {str(e)}") from e