通过解析事件获取 Pump.fun 代币铸造

本指南获取钱包在 Pump.fun 上部署的每个代币。它通过钱包的解析历史记录，直到历史记录耗尽，筛选出 Pump.fun 用于启动代币的两个指令。这是解析 Streams 指南跟踪 Pump.fun 铸造的历史对应版本：相同的程序、相同的指令名称和相同的解码字段——按需获取，而不是实时推送。

查看程序

Pump.fun 通过两个指令根据版本来启动代币：create 和 create_v2。解析事件通过与解析 Streams 相同的 IDL 目录解码指令，因此在匹配之前，通过其 describeProgram 方法确认确切的解码名称和账户角色：

Request

{ "jsonrpc": "2.0", "id": 1, "method": "describeProgram", "params": [{ "program": "6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P" }] }

检查响应的 instructions 列表中是否有 create 和 create_v2，以及在其 roles 列表中查找所需账户——通常是新的 mint 地址，和 creator 账户角色或 creator 字段在 args 中。两个指令版本不一定共享一个形状，这就是为什么下面的代码检查参数和几个角色名称而不是假设一个的原因。

构建请求

分页获取创建者钱包的历史记录：

{
  "address": "<CREATOR_WALLET>",
  "limit": 100,
  "sortOrder": "desc",
  "commitment": "confirmed"
}

值得提前了解三个与流过滤器的区别：

address 是必须的——不支持程序范围的扫描，所以您获取的是一个钱包的部署，而不是 Pump.fun 上的每个部署。对于信息流，使用解析 Streams。
请求没有服务器端指令过滤器。历史记录返回地址触及的所有内容，下一步是在客户端筛选出 Pump.fun 指令。
没有 includeFailed 开关。历史记录返回成功和失败的交易，因此在客户端检查 parsed.transactionStatus ——失败的部署永远不会产生活跃的铸造。

分页浏览历史记录

每个结果都携带交易的每个指令。扫描 parsed.instructions 以查找 create/create_v2 命中，并继续传递 paginationToken，直到它消失：

pumpfun-mint-history.js

const API_KEY = process.env.HELIUS_API_KEY;

if (!API_KEY) {
  console.error("Missing HELIUS_API_KEY.");
  process.exit(1);
}

const URL = `https://<ENDPOINT>/transaction-history?api-key=${API_KEY}`;
const PUMP_PROGRAM = "6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P";
const CREATE_INSTRUCTIONS = ["create", "create_v2"];
const CREATOR = process.argv[2];

if (!CREATOR) {
  console.error("Usage: node pumpfun-mint-history.js <CREATOR_WALLET>");
  process.exit(1);
}

async function fetchPage(paginationToken) {
  const body = {
    address: CREATOR,
    limit: 100,
    sortOrder: "desc",
    commitment: "confirmed",
  };
  if (paginationToken) body.paginationToken = paginationToken;

  const response = await fetch(URL, {
    method: "POST",
    headers: { "Content-Type": "application/json" },
    body: JSON.stringify(body),
  });
  if (!response.ok) {
    throw new Error(`HTTP ${response.status}: ${await response.text()}`);
  }
  return response.json();
}

async function main() {
  let paginationToken;
  let deployCount = 0;

  do {
    const page = await fetchPage(paginationToken);

    for (const result of page.data) {
      if (result.parserStatus !== "OK") continue;
      // Failed deploys never produce a live mint.
      if (result.parsed.transactionStatus !== "OK") continue;

      for (const ix of result.parsed.instructions) {
        if (ix.programId !== PUMP_PROGRAM) continue;
        if (!CREATE_INSTRUCTIONS.includes(ix.instructionName)) continue;
        deployCount += 1;
        handleDeploy(result, ix, deployCount);
      }
    }

    paginationToken = page.paginationToken;
  } while (paginationToken);

  console.log(`${deployCount} pump deploys found for ${CREATOR}`);
}

main();

提取每个部署

从解码指令中提取 mint、创建者和元数据，正如流监听器所做的那样：

// Pull an account pubkey out of a decoded instruction by its role name.
function accountByRole(decoded, role) {
  return decoded?.accounts?.find((a) => a.name === role)?.pubkey ?? null;
}

function handleDeploy(result, ix, deployCount) {
  const args = ix.decoded?.args ?? {};
  const mint = accountByRole(ix.decoded, "mint");
  const creator =
    args.creator ??
    accountByRole(ix.decoded, "creator") ??
    accountByRole(ix.decoded, "user");

  console.log(`pump deploy #${deployCount} (${ix.instructionName})`);
  console.log(`    mint:    ${mint}`);
  console.log(`    creator: ${creator}`);
  console.log(`    name:    ${args.name ?? "?"}`);
  console.log(`    symbol:  ${args.symbol ?? "?"}`);
  console.log(`    uri:     ${args.uri ?? "?"}`);
  console.log(`    slot=${result.parsed.slot} sig=${result.signature}`);
}

检查 ix.decoded 是否存在，然后才能信任 args 和 accounts ——否则，Pump.fun 程序的未识别构建将显示为 mint: null，仅能使用 rawData 和 rawAccounts。

下一步

跟踪 Pump.fun 铸造

实时版本：一个重新连接安全的监听器，记录每个新部署着陆时的情况。

入门

数据流 & 事件监听

数据 API & RPC

交易

发送交易

服务型钱包

指南

资源

通过解析事件获取 Pump.fun 代币铸造

下一步

跟踪 Pump.fun 铸造

​下一步

跟踪 Pump.fun 铸造

下一步