0

这是chainlink示例代码在这里，在这段代码中我只添加了1个oracle和1个job id，但问题是如何添加2个节点（2个oracles和2个job id）以从单个URL获取响应，即2个节点必须验证进入区块链之前的 URL 数据。

编译指示 ^0.6.0;

导入“@chainlink/contracts/src/v0.6/ChainlinkClient.sol”；

合约 APIConsumer 为 ChainlinkClient { uint256 public volume;

address private oracle;
bytes32 private jobId;
uint256 private fee;

/**
 * Network: Kovan
 * Chainlink - 0x2f90A6D021db21e1B2A077c5a37B3C7E75D15b7e
 * Chainlink - 29fa9aa13bf1468788b7cc4a500a45b8
 * Fee: 0.1 LINK
 */
constructor() public {
    setPublicChainlinkToken();
    oracle = 0x2f90A6D021db21e1B2A077c5a37B3C7E75D15b7e;
    jobId = "29fa9aa13bf1468788b7cc4a500a45b8";
    fee = 0.1 * 10**18; // 0.1 LINK
}

/**
 * Create a Chainlink request to retrieve API response, find the target
 * data, then multiply by 1000000000000000000 (to remove decimal places from data).
 */
function requestVolumeData() public returns (bytes32 requestId) {
    Chainlink.Request memory request =
        buildChainlinkRequest(jobId, address(this), this.fulfill.selector);

    // Set the URL to perform the GET request on
    request.add(
        "get",
        "https://min-api.cryptocompare.com/data/pricemultifull?fsyms=ETH&tsyms=USD"
    );

    // Set the path to find the desired data in the API response, where the response format is:
    request.add("path", "RAW.ETH.USD.VOLUME24HOUR");

    // Multiply the result by 1000000000000000000 to remove decimals
    int256 timesAmount = 10**18;
    request.addInt("times", timesAmount);

    // Sends the request
    return sendChainlinkRequestTo(oracle, request, fee);
}

/**
 * Receive the response in the form of uint256
 */

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

}

4

1 回答 1

1

可以在requestVolumeData函数中添加oracle和jobId参数，然后调用两次，每次传入不同的jobId和oracle。

uint[2] storage responses;   

function requestVolumeData(bytes32 _jobId, address _oracle) public returns (bytes32 requestId) {
Chainlink.Request memory request =
        buildChainlinkRequest(_jobId, address(this), this.fulfill.selector);

    // Set the URL to perform the GET request on
    request.add(
        "get",
        "https://min-api.cryptocompare.com/data/pricemultifull?fsyms=ETH&tsyms=USD"
    );

    // Set the path to find the desired data in the API response, where the response format is:
    request.add("path", "RAW.ETH.USD.VOLUME24HOUR");

    // Multiply the result by 1000000000000000000 to remove decimals
    int256 timesAmount = 10**18;
    request.addInt("times", timesAmount);

    // Sends the request
    return sendChainlinkRequestTo(_oracle, request, fee);
}

然后在您的完成函数中，您可以将结果存储在数组或其他一些数据结构中，以便第二个响应不会覆盖第一个响应。或者每个响应有 1 个变量，并且有逻辑来检查要填充哪个变量（如果两者都为空，则首先填充，否则填充第二个等）。在此功能中，您还可以检查是否已达到最小响应数量，如果已达到，则对响应进行验证

function fulfill(bytes32 _requestId, uint256 _volume)
public recordChainlinkFulfillment(_requestId)
{
    responses.push(_volume)
    if responses.length > some number {
       //do something with the responses
    }
}
于 2021-06-21T01:30:10.970 回答