区块链数据集成

import { SortXYZBlockchainLoader } from "@langchain/community/document_loaders/web/sort_xyz_blockchain";
import { OpenAI } from "@langchain/openai";

/**
 * 请参阅 https://docs.sort.xyz/docs/api-keys 获取您的免费 Sort API 密钥。
 * 请参阅 https://docs.sort.xyz 了解可用查询的更多信息。
 * 请参阅 https://docs.sort.xyz/reference 了解 Sort REST API 的更多信息。
 */

/**
 * 运行示例。
 */
export const run = async () => {
  // 初始化 OpenAI 模型。使用 /examples 中 .env 文件里的 OPENAI_API_KEY
  const model = new OpenAI({ temperature: 0.9 });

  const apiKey = "YOUR_SORTXYZ_API_KEY";
  const contractAddress =
    "0x887F3909C14DAbd9e9510128cA6cBb448E932d7f".toLowerCase();

  /*
  从以太坊区块链加载 NFT 元数据。提示：要按特定 ID 加载，请参阅下面的 SQL 查询示例。
  */

  const nftMetadataLoader = new SortXYZBlockchainLoader({
    apiKey,
    query: {
      type: "NFTMetadata",
      blockchain: "ethereum",
      contractAddress,
    },
  });

  const nftMetadataDocs = await nftMetadataLoader.load();

  const nftPrompt =
    "用以下 JSON 文档中的属性，用一个 4 句话的故事来描述这个角色。";
  const nftResponse = await model.invoke(
    nftPrompt + JSON.stringify(nftMetadataDocs[0], null, 2)
  );
  console.log(`user > ${nftPrompt}`);
  console.log(`chatgpt > ${nftResponse}`);

  /*
    从以太坊区块链加载合约地址的最新交易记录。
  */
  const latestTransactionsLoader = new SortXYZBlockchainLoader({
    apiKey,
    query: {
      type: "latestTransactions",
      blockchain: "ethereum",
      contractAddress,
    },
  });

  const latestTransactionsDocs = await latestTransactionsLoader.load();

  const latestPrompt =
    "仅用每个文档 4 句话来描述以下 JSON 文档。尽可能包含更多细节。";
  const latestResponse = await model.invoke(
    latestPrompt + JSON.stringify(latestTransactionsDocs[0], null, 2)
  );
  console.log(`\n\nuser > ${nftPrompt}`);
  console.log(`chatgpt > ${latestResponse}`);

  /*
    使用原始 SQL 和 NFT 索引加载特定 NFT 的元数据。请参阅 https://docs.sort.xyz 了解如何构建 SQL。
  */

  const sqlQueryLoader = new SortXYZBlockchainLoader({
    apiKey,
    query: `SELECT * FROM ethereum.nft_metadata WHERE contract_address = '${contractAddress}' AND token_id = 1 LIMIT 1`,
  });

  const sqlDocs = await sqlQueryLoader.load();

  const sqlPrompt =
    "用以下 JSON 文档中的属性，为一个新咖啡店写一则广告来描述这个角色。";
  const sqlResponse = await model.invoke(
    sqlPrompt + JSON.stringify(sqlDocs[0], null, 2)
  );
  console.log(`\n\nuser > ${sqlPrompt}`);
  console.log(`chatgpt > ${sqlResponse}`);
};