文件名称：Erlang事件处理库RivusCEP.zip
文件大小：999KB
文件格式：ZIP
更新时间：2022-08-05 21:40:20
开源项目
Rivus CEP 是一个 Erlang 库用于复杂的事件处理，使用声明式的类似 SQL 的 DSL 来定义事件流的操作。 示例代码： application:start(rivus_cep). QueryStr = "define correlation2 as select ev1.eventparam1, ev2.eventparam2, sum(ev2.eventparam3) from event1 as ev1, event2 as ev2 where ev1.eventparam2 = ev2.eventparam2 within 60 seconds; ". Producer = event_producer_1. {ok, SubscriberPid} = result_subscriber:start_link(). {ok, QueryPid} = rivus_cep:load_query(QueryStr, [Producer], [SubscriberPid], [{shared_streams, true}]). %% create some evetnts Event1 = {event1, gr1,b,10}. Event2 = {event2, gr2,bbb,20}. %% send the events rivus_cep:notify(Producer, Event1). rivus_cep:notify(Producer, Event2). %% or if you don't care about the producers rivus_cep:notify(Event1). rivus_cep:notify(Event2). 标签：Rivus
【文件预览】：
rivus_cep-master
----LICENSE.txt(11KB)
----priv()
--------basho_bench_driver_rivus.erl(2KB)
--------rivus_cep_event_gen.erl(373B)
--------rivus.config(582B)
----src()
--------rivus_cep_query_worker_sup.erl(1KB)
--------rivus_cep_tcp_listener.erl(2KB)
--------gen_nb_server.erl(6KB)
--------rivus_cep.erl(10KB)
--------rivus_cep_query_worker.erl(4KB)
--------rivus_cep.app.src(305B)
--------rivus_cep_server.erl(5KB)
--------rivus_cep_scanner.xrl(3KB)
--------erlydtl_custom_filters.erl(131B)
--------rivus_cep_event_creator.erl(3KB)
--------rivus_cep_utils.erl(97B)
--------rivus_cep_parser.erl(78KB)
--------rivus_cep_clock_server.erl(3KB)
--------rivus_cep_app.erl(2KB)
--------rivus_cep_scanner.erl(35KB)
--------rivus_cep_query.erl(15KB)
--------rivus_cep_window_ets.erl(4KB)
--------rivus_cep_query_planner.erl(11KB)
--------rivus_cep_app_srv.erl(5KB)
--------rivus_cep_tcp_listener_sup.erl(3KB)
--------event_behaviour.erl(195B)
--------result_subscriber.erl(682B)
--------rivus_cep_app_srv_sup.erl(1016B)
--------rivus_cep_result_eval.erl(7KB)
--------rivus_cep_parser.yrl(11KB)
--------rivus_cep_window.erl(7KB)
--------rivus_cep_sup.erl(1KB)
--------rivus_cep_clock_sup.erl(1KB)
--------rivus_cep_server_sup.erl(1KB)
----rebar(179KB)
----rel()
--------vars.config(218B)
--------reltool.config(2KB)
--------files()
----relx.config(1KB)
----.travis.yml(43B)
----test()
--------rivus_cep_server_tests.erl(6KB)
--------rivus_cep_query_worker_tests.erl(7KB)
--------event4.erl(375B)
--------rivus_cep_window_tests.erl(11KB)
--------rivus_cep_event_creator_tests.erl(864B)
--------rivus_cep_query_planner_tests.erl(10KB)
--------rivus_cep_parser_tests.erl(12KB)
--------rivus_cep_window_ets_tests.erl(8KB)
--------event3.erl(423B)
--------rivus_cep_result_eval_tests.erl(2KB)
--------event2.erl(424B)
--------event5.erl(381B)
--------event1.erl(424B)
--------rivus_cep_tests.erl(17KB)
----README.md(9KB)
----relx(744KB)
----rebar.config(610B)
----.gitignore(175B)
----include()
--------rivus_cep.hrl(2KB)