如何在查询wso2 sp复杂的json处理中进行过滤。

Question

我有一个要求执行一个复杂的json处理，我几乎已经完成了，但是遇到了一个基于属性过滤事件的逻辑。我知道一般的过滤，但这是一个在from语句旁边写tokenizeAsObject函数的情况。在这种情况下，过滤部分应该写在哪里，如何写？

--THE CODE GOES HERE
    @App:name('CompanyClientDetailingApp3')
@App:description('Description of the client details of the company')

@source(type='http', receiver.url='http://localhost:5005/clientDetails',
    @map(type='json', @attributes(json = '$')
    )
)
define stream CompanyClientStream3 (json string);

@sink(type = 'log', 
    @map(type = 'passThrough'))
define stream EachProjectStream3 (Client string, clientContractTerm string, projectName string, projectContractTerm int);

@info(name = 'clientProjectquery')
from CompanyClientStream3#json:tokenizeAsObject(json, '$.CompanyClients') 
select json:getString(jsonElement, '$.Client') as Client, json:getString(jsonElement, '$.Invoice.ContractTerm') as clientContractTerm, json:getObject(jsonElement, '$.Invoice.Projects') as projectList 
insert into EachClientProjectStream3;

@info(name = 'projectSttreamQuery')
from EachClientProjectStream3#json:tokenizeAsObject(projectList, "$") 
select Client, clientContractTerm, json:getString(jsonElement, '$.ProjectName') as projectName, json:getInt(jsonElement, '$.ProjectTerm') as projectContractTerm 
insert into EachProjectStream3;

筛选是基于ProjectTerm.i.e.Projecterm > 5年的项目必须被流出来。

--Inputs for the same

{
 "CompanyClients": [
   {
     "Client": "C1",
     "Invoice": {
       "ContractTerm": "5",
       "Unit": "years",
       "Projects": [
         {"ProjectName":"C1P1", "ProjectTerm":"5", "TermUnit": "years"},
         {"ProjectName":"C1P2", "ProjectTerm":"3", "TermUnit": "years"},
         {"ProjectName":"C1P3", "ProjectTerm":"2", "TermUnit": "years"}
       ]
     }
   },
   {
     "Client": "C3",
     "Invoice": {
       "ContractTerm": "10",
       "Unit": "years",
       "Projects": [
         {"ProjectName":"C3P1", "ProjectTerm":"8", "TermUnit": "years"},
         {"ProjectName":"C3P2", "ProjectTerm":"5", "TermUnit": "years"},
         {"ProjectName":"C3P3", "ProjectTerm":"6", "TermUnit": "years"}
       ]
     }
   }
 ]
}

谢谢，Kaushik。

Answer 1

从EachProjectStream3的输出可以在连续查询过滤。

from EachProjectStream3[projectContractTerm < 5]
slect *
insert into FilteredStream;