函数代码

​

入口约定

1. functionId 的最后一段。例如注册函数 token.trace_to_token_transfer 的入口是 def trace_to_token_transfer。
2. 名为 _ 的顶层 def，或者一行 _ = <函数名> 别名。blockx-py 把 Python callable 打包成源码时会自动补这行别名。
3. 源码顺序里第一个不以 _ 开头的顶层 def。

def _(chain_id, record):
    value = float(record.get("value") or 0)
    if value <= 0 or not record.get("tx_id"):
        return None
    return {
        "id": record["id"],
        "chain_id": chain_id,
        "from_addr": record["from_addr"],
        "to_addr": record["to_addr"],
        "value": value,
    }

​

参数与返回值

​

函数从哪里来

​

版本固定

• task 激活时固定一个快照 epoch；这个 task 的所有 call 和子调用都按同一份快照解析函数，热更新只影响之后提交的 task。
• 派发给 Executor 的只有源码 digest。Executor 按 digest 缓存编译产物，未命中时按 digest 向 Worker 回拉源码。
• 同一 task 内，把同一个 functionId 绑到不同源码，或 inline 函数与快照函数撞名，都会让这个 ID 确定性失败。

​

函数里能做什么

• 直接写 BlockDB。所有写入走 task 声明的 Writer Plugin。
• 绕过 SDK 访问外部服务。审计开启时 import 只能拿到白名单模块。
• 跨 call 共享状态。模块命名空间按 task 隔离，call 之间没有顺序。

​

执行预算

• 单个 call 的执行预算是 CallDeadlineMs = 5000，只计 CPU 与 IO 后端时间，不含排队；超出即该 call 失败。
• 纯 CPU 循环由 Executor 的 SIGALRM 定时器抢占，IO 等待期间 greenlet 让出。
• call 预算与 task 超时相互独立；task 超时以 TIMED_OUT 收敛整个 task。

​

静态审计

​

小结

• 入口优先按 functionId 最后一段找，其次是 _，最后是第一个公开 def。
• 参数按位置传入，扫描类 Builder 用 "${表名}"（SOURCE_ROW）占位放入行 dict；返回 dict / list[dict] / None。
• 函数只读；IO 全部经 SDK 拦截回 Worker；写入由 Writer Plugin 完成。
• 每个 task 固定一份代码快照；单 call 预算 5 秒；审计 enforce 模式 fail-closed。

• Function Code View：快照、epoch、syncer 与审计链路的实现。
• Python Executor：用户函数编程模型、greenlet 挂起与 SDK 拦截点。
• Call Builder 与 Writer Plugin：params 模板与返回值如何落表。
• 提交 task 示例：完整可运行的函数与 task。