在从 Chainlink 预言机节点获得数据之前，我们首先需要创建一个用户合约，然后在用户合约中给 Chainlink 预言机节点发送一个请求。下面的代码将展示如何通过用户合约给预言机节点发送请求：

function requestVolumeData() public returns (bytes32 requestId) {  Chainlink.Request memory req = buildChainlinkRequest(jobId, address(this), this.fulfill.selector);  req.add('get', 'https://min-api.cryptocompare.com/data/pricemultifull?fsyms=ETH&tsyms=USD');
  req.add('path', 'RAW,ETH,USD,VOLUME24HOUR');
  int256 timesAmount = 10**18;  req.addInt('times', timesAmount);
  return sendChainlinkRequest(req, fee);}

Chainlink AnyAPI 获取的数据的方式一般是通过预言机节点给外部数据源发送 RESTful 请求，所以节点在发送请求之前需要知道要请求的数据的 API 和参数。为了给 Any API 提供必要的数据，在智能合约的 `ChainlinkRequest` 中，我们需要通过函数 `buildChainlinkRequest` 加入这些相关信息。`buildChainlinkRequest` 这个函数定义在 `ChainlinkClient.sol`，代码展示如下：

function buildChainlinkRequest(  bytes32 specId,   address callbackAddr,   bytes4 callbackFunctionSignature)  internal  pure  returns (Chainlink.Request memory) {     Chainlink.Request memory req;     return req.initialize(specId, callbackAddr, callbackFunctionSignature);}

在 `buildChainlinkRequest` 函数中，所有与请求相关的信息都会加入到 Request 这个结构体中，并且调用函数 `initialize` 来完成初始化。

Struct Request定义在 Chainlink.sol 文件中，代码如下：

struct Request {  bytes32 id;  address callbackAddress;  bytes4 callbackFunctionId;  uint256 nonce;  BufferChainlink.buffer buf;}

函数 `initialize` 也定义在 Chainlink.sol 文件中，代码如下：

function initialize(  Request memory self,  bytes32 jobId,  address callbackAddr,  bytes4 callbackFunc)  internal  pure  returns (Chainlink.Request memory) {   BufferChainlink.init(self.buf, defaultBufferSize);   self.id = jobId;   self.callbackAddress = callbackAddr;   self.callbackFunctionId = callbackFunc;   return self;}

在函数 `buildChainlinkRequest` 中，会接受 3 个参数：

在这三个参数设置好以后，还需要加入 URL 和数据路径，因为我们需要告诉预言机节点通过哪个 API 获取数据，并且在获取数据以后，如何在返回的数据中找到我们所需要的有效数据。

req.add('get', 'https://min-api.cryptocompare.com/data/pricemultifull?fsyms=ETH&tsyms=USD');
req.add('path', 'RAW,ETH,USD,VOLUME24HOUR');

这里的 `path` 参数很重要，因为预言机通常会通过用户提供的 URL 获得庞大而杂乱的数据，下面的 JSON 数据就是一个例子。

{"RAW":   {"ETH":     {"USD":      {"TYPE":"5",       "MARKET":"CCCAGG",       "FROMSYMBOL":"ETH",       "TOSYMBOL":"USD",       "FLAGS":"2049",       "PRICE":1083.43,       "LASTUPDATE":1655472805,       "MEDIAN":1083.49,       "LASTVOLUME":0.01152796,       "LASTVOLUMETO":12.488815466,       "LASTTRADEID":"298687546",       "VOLUMEDAY":279647.314121829,       "VOLUMEDAYTO":304661021.9293905,       "VOLUME24HOUR":617393.32461219,       .......       .......       "TOTALTOPTIERVOLUME24HTO":"$ 5.47B",       "IMAGEURL":"/media/37746238/eth.png"}      }    } }

通过在 request 中的 path 数据，预言机节点才可以获取到我们所想要的数据。所以在 URL 和路径被设置好以后，这个 `chainlinkRequest` 就完成并且可以被发送了。

return sendChainlinkRequest(req, fee);

这里的调用顺序是：

让我们看一个具体的例子，Chainlink 官方在测试网 Kovan 中所部署了一个预言机合约。这个合约的代码可以在这里看到：

https://kovan.etherscan.io/address/0x74EcC8Bdeb76F2C6760eD2dc8A46ca5e581fA656#code

function oracleRequest(    address sender,    uint256 payment,    bytes32 specId,    address callbackAddress,    bytes4 callbackFunctionId,    uint256 nonce,    uint256 dataVersion,    bytes calldata data  ) external override validateFromLINK {    (bytes32 requestId, uint256 expiration) = _verifyAndProcessOracleRequest(      sender,      payment,      callbackAddress,      callbackFunctionId,      nonce,      dataVersion    );    emit OracleRequest(specId, sender, requestId, payment, sender, callbackFunctionId, expiration, dataVersion, data);  }

在代码中，可以很容易看到，这个函数就是把所有的信息写到了 event log 中，然后等待链下的预言机节点检测。

返回数据的函数 `fulfillOracleRequest2` 也被定义在 `OperatorInterface.sol` 文件中。

function fulfillOracleRequest2(bytes32 requestId,uint256 payment,address callbackAddress,bytes4 callbackFunctionId,uint256 expiration,bytes calldata data) external returns (bool);

让我们看看刚才的合约中，这个函数中的逻辑是什么样的：

function fulfillOracleRequest2(    bytes32 requestId,    uint256 payment,    address callbackAddress,    bytes4 callbackFunctionId,    uint256 expiration,    bytes calldata data)    external    override    validateAuthorizedSender    validateRequestId(requestId)    validateCallbackAddress(callbackAddress)    validateMultiWordResponseId(requestId, data)    returns (bool){    _verifyOracleRequestAndProcessPayment(requestId, payment, callbackAddress, callbackFunctionId, expiration, 2);    emit OracleResponse(requestId);    require(gasleft() >= MINIMUM_CONSUMER_GAS_LIMIT, "Must provide consumer enough gas");
    (bool success, ) = callbackAddress.call(abi.encodePacked(callbackFunctionId, data));    return success;  }

通过上面的代码，我们看到这个函数调用了 `callbackAddress` 地址合约中的一个函数，这个地址就是之前传给预言机合约的用户合约地址。用户合约中 `fullfill` 函数被调用了:

function fulfill(bytes32 _requestId, uint256 _volume) public recordChainlinkFulfillment(_requestId) {        emit RequestVolume(_requestId, _volume);        volume = _volume;    }

这个展示合约中的 fulfill 函数非常简单，就是将 requestId 和 volume 的数据写入 event log，然后将 volume 写入到本地变量 _volume 中。

在上一章节，我们了解了如何在用户合约中使用 Chainlink AnyAPI服务，以获取到多种多样的数据。接下来，我们来看看如何去运行 Chainlink AnyAPI 的“后端”，来看看如何运行一个预言机节点来帮助链上合约获取它们所需要的各种数据。

新建节点有很多种方式，如果你是一个运维人员并且自身有足够的硬件资源，可以根据官方文档中的教程新建一个节点。如果你不想要自己运维节点，那么可以选择使用 naas.link（node as a service），只需要点几个按钮就可以新建一个节点，并且是免费的。另外，Chainlink 官方开发者关系团队也在不同的链上维护了一些 Chainlink 节点，可以在这里查看关于这些节点的 JobId，合约地址和其他相关信息：

https://docs.chain.link/docs/decentralized-oracles-ethereum-mainnet/

如果你需要一些特殊的数据，比如说天气数据，股票数据，体育比赛数据等等，可以在 Chainlink 提供的数据市场 market.link 中搜索。

如果你对于Chainlink节点所提供的数据有更个性化的要求，可以登陆 Chainlink 的 Discord，Chainlink 团队会帮你在社区中联系节点运营商，以满足你的需求。华语开发者也可以直接联系 Chainlink 中国团队，获得更快的响应。

在上一章节，我们了解了如何去写一个用户合约来使用 Chainlink AnyAPI ，从而获取到多种多样的数据。接下来，我们可以学习一下如何去运行 AnyAPI 的“后端”，来看看如何运行一个预言机节点来帮助链上合约获取它们所需要的各种数据。

TOML（Tom's Obviously Minimal Language）是一种配置文件的格式，因为 sematics 比较清晰，所以更容易阅读，被很多项目所使用。Chainlink 节点就是使用 TOML 来定义节点所提供的 API 服务所对应的 job 的详细信息。

在 Chainlink 节点中，每一个 jobId 都会代表一个在节点中运行的 job。比如说在 API 样例代码中，jobId 代表的 job 是获取 BTC 昨天的市场数据的。Chainlink 节点使用 TOML 来定义怎么样从 API 中获取数据，并且将这个数据进行标准化，使其可以被用户合约使用。

Chainlink 节点做的任何操作都会依赖于 job，现在支持以下 6 种 job：

在 job 中，需要定义以下变量：

除了上述参数以外，你还需要定义 job 中的任务（task），让我们看看一个 job 的 TOML 文件的例子：

type                = "directrequest"schemaVersion       = 1evmChainID          = 1name                = "example eth request event spec"contractAddress     = "0x613a38AC1659769640aaE063C651F48E0250454C"

observationSource   = """    ds          [type="http" method=GET url="http://example.com"]    ds_parse    [type="jsonparse" path="USD"]    ds_multiply [type="multiply" times=100]
    ds -> ds_parse -> ds_multiply

`ds`, `ds_parse`, `ds_multiply` 是 job 要执行的 3 个任务，执行顺序通过 `ds -> ds_parse -> ds_multiply` 这一行定义，语法非常简单，即先给 “http://exmpale.com” 发送 GET 请求，然后使用路径 “USD” 来找到用户在这个JSON 文件中需要的值。这个 JSON 文件如下：

{   usd: number}

最后，这个 job 会根据 `ds_multiply` 这个任务将结果乘以 100。

除了可以通过 Chainlink data feed 获取通证价格以外，开发还可以通过 Chainlink AnyAPI 获得任何自己想要的数据。文章讲解了如何新建自己的 Chainlink 节点，并且在合约中使用 Chainlink 节点 AnyAPI 服务获得个性化数据。

您可以关注 Chainlink 预言机并且私信加入开发者社区，有大量关于智能合约的学习资料以及关于区块链的话题！