#384 Stream Explorer - References

Let's go back to our order exploration app -

Remember, this is what our input file looked like.

Now, as chance would have it, I have a DB table which contains the inventory status of
our products. We can add data from this table to our exploration as a reference.

To begin with, we need to add a data source definition to OEP -

Now I go to Stream Explorer and create the Reference -

Now we can add this to the Exploration

Just click on the Sources panel -

We now need to add a correlation between the two sources -

Join on Product -

I delete the summary, group by and filter -

Product is listed twice, but we can solve this easily -

Note the colour coding above.

#383 Oracle Stream Explorer / OEP basics

Just to demo Stream Explorer interaction with OEP -
I login to the OEP console -

Note the url http://localhost:9002

Check out the domain -

Here we see the app, created in the previous post -

We see the csv inbound adapter etc.

Now I will show you how to export the app, created in Stream Explorer, and then how
to import the very same app into JDeveloper 12c.

I open the Exploration in Stream Explorer and then click on Actions -
I select Export.

I copy this jar to my OEP home for housekeeping purposes.

I now start JDeveloper and then import the OEP bundle.

First I create an OEP application with a default project.
I then delete the project.

I now do the import -

Point to the exported jar -

Here is the imported App -

Here is the EPN diagram -

Before we check out the generated CQL, here is the query definition
from Stream Explorer  -

Remember, we are looking at the total spend of individual customers,
over a rolling time window of 5 minutes. We are only interested in high
spenders, i.e. those spending more than 10K.

This is our business user friendly definition from Stream Explorer -

Here is the generated CQL in the OEP app -

Great stuff, this Stream Explorer!

# 331 - OEP 12c leveraging EDN Lab

Here is a simple lab that shows OEP and EDN in action.

With 12c, OEP now includes EDN adapters.

My simple scenario -

A SOA composite receives messages of type MyCCTx. It then publishes an EDN event, NewCreditCardTXEvent. OEP has an EDN inbound adapter subscribing to this event. It then processes the event, applying the following rules –

·         Individual transactions must be under €1000.

o   Those over €1000 will be highlighted as fraud.

·         During a ten minute time range, the total transaction values must be under €1500.

o   i.e. 2 transactions, on the same card, for 800€ and 900€ occurring within ten minutes of each other will be highlighted as fraud.

For each event, OEP will publish an EDN event – CreditCardTxCheckedEvent.

The SOA composite also subscribes to the CreditCardTxCheckedEvent event, published by OEP. It writes all results to a file.

My XSD is as follows -

Here is the SOA Composite - it includes 2 Mediators

The OEP EPN is as follows -

The inbound EDN adapter subscribes to the NewCreditCardTXEvent.

The outbound EDN adapter publishes the event CreditCardTXCheckedEvent.

Full lab doc here

#329 Oracle Event Processing book from Packt

Excellent book from Lloyd et al.

Applicable to OEP 12c.