文档

使用过滤器

更新时间:

在配置云服务集成触发器时,您可以为触发器配置过滤器,以便对区块链数据进行过滤和简单的处理。区块链各类事件的数据结构请参考Fabric示例消息。 过滤器表达式遵循的语法请参考jq工具基本语法

下面介绍如何使用过滤器对区块链事件进行过滤和简单的预处理,本示例通过函数计算触发器来演示功能,您需要按如下步骤准备环境:

  1. 下载云服务集成示例代码

  2. 安装函数计算工具 Serverless Devs,具体可参见 Serverless Devs介绍及安装方式

  3. 进入目录 event-with-filter 使用 s deploy 将函数部署到函数计算。

  4. 进入函数计算控制台,为我们刚才创建的函数 LoggerFunc 开通日志查询。

    image.png
  5. 按照文档部署链码将示例链码 taskmgr 部署到通道中。

  6. 配置云服务集成触发器:

    1. 根据帮助,填写函数计算实例的相关信息。

    2. 在高级选项中,根据以下不同的示例场景,填写过滤器表达式。

  7. 进入 blockchain2sms 目录,按照注释修改 main.js 中的配置参数,填入REST API地址、Refresh Token、通道名和智能合约名称。更多信息请参考文档使用REST API

  8. 执行 npm install 安装依赖包,通过 node main.js 发起示例交易。

  9. 查看函数计算的日志,观察收到的事件内容。

示例场景

一、只推送满足特定条件的事件

只推送智能合约事件名称为 event-create-task 的事件:

  • 事件类型选择: Contract

  • 过滤器配置: select(.name=="event-create-task")

  • 推送数据示例:

{
  "content": "eyJuYW1lIjoidGFzay0xNTgwOTcxODQyOTM3IiwiY3JlYXRvciI6ImUyZWhtZnFhc3RoTVNQLm9jdG9wdXNfMjY4NDJfMTIzNDU2Nzg5MDEyMzQiLCJyZXF1aXJlcyI6WyJlMmVobWZxYXN0aE1TUC5vY3RvcHVzXzI2ODQyXzEyMzQ1Njc4OTAxMjM0Il0sImFwcHJvdmVkIjpudWxsLCJkZXNjcmlwdGlvbiI6IuekuuS+i+S7u+WKoe+8jHJlcXVpcmVzIOmFjee9ruWuoeaJueS7u+WKoeWujOaIkOmcgOimgemCo+S6m+eUqOaIt+WQjOaEj+OAgueUqOaIt+aPj+i/sOS4uiAn57uE57uHTVNQLueUqOaIt+WQjeensCcifQ==",
  "id": "contract-131-ca144c3385f56a429b9e8874173f7c97fbb49de69f931aec583ec50222a3a2ed",
  "instance_id": "csi-e2ehmfqasth-bcw7tzao2dzeo",
  "name": "event-create-task",
  "network": "channel3",
  "platform": "Fabric",
  "type": "Contract"
}

二、只推送有效的特定交易事件

只推送发送给智能合约 taskmgr 的交易,且交易状态为有效:

  • 事件类型选择: Tx

  • 过滤器配置:select(.content.to=="taskmgr" and .content.state=="VALID")

  • 推送数据示例:

    {
    "content": {
      "events": [
        "event-create-task"
      ],
      "from": "e2ehmfqasthMSP.octopus_26842_12345678901234",
      "id": "3a2e0e375c6ee0d9c6c20d756e787db44d50bfeba51f22d8f262dd1556dedba0",
      "input": "[\"create\",\"task-1580971842937\",\"{\\n \\\"requires\\\": [\\\"e2ehmfqasthMSP.octopus_26842_12345678901234\\\"],\\n \\\"description\\\": \\\"示例任务,requires 配置审批任务完成需要那些用户同意。用户描述为 '组织MSP.用户名称'\\\"\\n }\"]",
      "state": "VALID",
      "to": "taskmgr"
    },
    "id": "tx-128-3a2e0e375c6ee0d9c6c20d756e787db44d50bfeba51f22d8f262dd1556dedba0",
    "instance_id": "csi-e2ehmfqasth-bcw7tzao2dzeo",
    "name": "3a2e0e375c6ee0d9c6c20d756e787db44d50bfeba51f22d8f262dd1556dedba0",
    "network": "channel3",
    "platform": "Fabric",
    "type": "Tx"
    }

三、只推送事件的部分内容

只推送智能合约事件的内容,且事件的名称为 event-create-task:

  • 事件类型选择: Contract

  • 过滤器配置:select(.name=="event-create-task") | .content

  • 推送数据示例:

    "eyJuYW1lIjoidGFzay0xNTgwOTcxODQyOTM3IiwiY3JlYXRvciI6ImUyZWhtZnFhc3RoTVNQLm9jdG9wdXNfMjY4NDJfMTIzNDU2Nzg5MDEyMzQiLCJyZXF1aXJlcyI6WyJlMmVobWZxYXN0aE1TUC5vY3RvcHVzXzI2ODQyXzEyMzQ1Njc4OTAxMjM0Il0sImFwcHJvdmVkIjpudWxsLCJkZXNjcmlwdGlvbiI6IuekuuS+i+S7u+WKoe+8jHJlcXVpcmVzIOmFjee9ruWuoeaJueS7u+WKoeWujOaIkOmcgOimgemCo+S6m+eUqOaIt+WQjOaEj+OAgueUqOaIt+aPj+i/sOS4uiAn57uE57uHTVNQLueUqOaIt+WQjeensCcifQ=="

四、获取区块链的写入情况

只推送智能合约 taskmgr 中所有 Key 的写入情况,且状态为有效的交易:

  • 事件类型选择: Tx

  • 过滤器配置:select(.content.state=="VALID" and .content.to=="taskmgr") | .content.data.data.actions.[0].payload.action.proposal_response_payload.extension.results.ns_rwset[] | select(.namespace=="taskmgr") | .rwset.writes

  • 推送数据示例:

    [{"is_delete":false,"key":"\u0000e2ehmfqasthMSP.octopus_26842_12345678901234\u0000task-1581479306267\u0000","value":"eyJuYW1lIjoidGFzay0xNTgwOTcxODQyOTM3IiwiY3JlYXRvciI6ImUyZWhtZnFhc3RoTVNQLm9jdG9wdXNfMjY4NDJfMTIzNDU2Nzg5MDEyMzQiLCJyZXF1aXJlcyI6WyJlMmVobWZxYXN0aE1TUC5vY3RvcHVzXzI2ODQyXzEyMzQ1Njc4OTAxMjM0Il0sImFwcHJvdmVkIjpudWxsLCJkZXNjcmlwdGlvbiI6IuekuuS+i+S7u+WKoe+8jHJlcXVpcmVzIOmFjee9ruWuoeaJueS7u+WKoeWujOaIkOmcgOimgemCo+S6m+eUqOaIt+WQjOaEj+OAgueUqOaIt+aPj+i/sOS4uiAn57uE57uHTVNQLueUqOaIt+WQjeensCcifQ=="}]

五、对特定Key进行监控

监控智能合约 taskmgr 中特定 Key 的 Value 变化情况,且状态为有效的交易:

  • 事件类型选择: Tx

  • 过滤器配置:select(.content.state=="VALID" and .content.to=="taskmgr") | .content.data.data.actions.[0].payload.action.proposal_response_payload.extension.results.ns_rwset[] | select(.namespace=="taskmgr") | .rwset.writes[] | select(.key=="special_key")

  • 推送数据示例:

    {"is_delete":false,"key":"special_key","value":"MTA="}

六、导出数据到数据库表

利用过滤器我们可以将区块链数据导出至数据库的自定义表中。过滤器对数据进行处理转换成一个Object的数组,每个Object表示需要插入的一行数据,Object的Key为表的列名,Value为需要插入的数据:

[
  {
    "columnName1": "value1",
    "columnName2": "value2",
    "columnName3": "value3",
  },
  {
    "columnName1": "value3",
    "columnName2": "value4",
    "columnName3": "value5",
  },
  ...
]

将智能合约 taskmgr 所有合法交易的写入内容导出到以下表中:

  • 表结构:

    • 主键: (event_id,namespace,key)

    • event_id, 事件ID

    • namespace, 写入的命名空间(智能合约名称)

    • key, 写入的Key

    • value, 经过Base64编码的写入值

    • create_time, 写入的时间

    • tx_id, 对应的交易ID

    • is_delete, 是否为删除操作

    • creator, 写入操作的发起者

  • 过滤器配置:select(.content.state=="VALID" and .content.to=="taskmgr") | .id as $eventID | .content.id as $txID | .content.from as $creator | content.data.header.channel_header.timestamp as $createTime | .content.data.data.actions.[0].payload.action.proposal_response_payload.extension.results.ns_rwset | ap(.namespace as $namespace | .rwset.writes | map( .event_id = $eventID | .namespace = $namespace | .tx_id = $txID | .create_time = $createTime | .creator = $creator )) | dd

  • 事件类型选择: Tx

  • 推送数据示例:

    [
    {
      "event_id": "tx-128-3a2e0e375c6ee0d9c6c20d756e787db44d50bfeba51f22d8f262dd1556dedba0",
      "namespace": "taskmgr",
      "tx_id": "3a2e0e375c6ee0d9c6c20d756e787db44d50bfeba51f22d8f262dd1556dedba0",
      "is_delete": false,
      "key": "\u0000e2ehmfqasthMSP.octopus_26842_12345678901234\u0000task-1581479306267\u0000",
      "value": "eyJuYW1lIjoidGFzay0xNTgwOTcxODQyOTM3IiwiY3JlYXRvciI6ImUyZWhtZnFhc3RoTVNQLm9jdG9wdXNfMjY4NDJfMTIzNDU2Nzg5MDEyMzQiLCJyZXF1aXJlcyI6WyJlMmVobWZxYXN0aE1TUC5vY3RvcHVXzI2ODQyXzEyMzQ1Njc4OTAxMjM0Il0sImFwcHJvdmVkIjpudWxsLCJkZXNjcmlwdGlvbiI6IuekuuS+i+S7u+WKoe+8jHlcXVpcmVzIOmFjee9ruWuoeaJueS7u+WKoeWujOaIkOmcgOimgemCo+S6m+eUqOaIt+WQjOaEj+OAgueUqOaIt+aPj+i/sOS4uiAn57uE57uHTVNQLueUqOaIt+WQjeensCcifQ==",
      "create_time": "2020-02-06T06:50:42.267092Z",
      "creator": "e2ehmfqasthMSP.octopus_26842_12345678901234"
    }
    ]
  • 本页导读 (0)
文档反馈