如何将特定格式文本文件数据存入Esper引擎用于EPL语句？

我来帮你梳理下怎么把文本文件里的静态数据导入Esper，并且实现事件和这些数据的条件匹配逻辑——这其实是Esper里外部数据关联的典型场景，咱们一步步来：

首先得给你的文本数据和传入事件都定义Esper能识别的事件类型，不管用Java类还是Esper动态声明都可以，这里用Java类示例更直观：

• 先定义文本里的静态参考数据类型，比如叫ReferenceData：

public class ReferenceData {
    private String code; // 对应XYZ、ABC这类3字符字符串
    private int value;   // 对应120、200这类整数值

    // 必须要有构造器和getter，Esper需要通过反射访问属性
    public ReferenceData(String code, int value) {
        this.code = code;
        this.value = value;
    }

    public String getCode() { return code; }
    public int getValue() { return value; }
}

• 再定义你要传入的业务事件类型，比如叫IncomingEvent（假设事件里包含匹配用的code和触发值）：

public class IncomingEvent {
    private String eventCode;
    private int eventValue;

    // 同样需要构造器和getter方法
    public IncomingEvent(String eventCode, int eventValue) {
        this.eventCode = eventCode;
        this.eventValue = eventValue;
    }

    public String getEventCode() { return eventCode; }
    public int getEventValue() { return eventValue; }
}

Esper里可以用keepall窗口来持久化存储静态参考数据（因为数据不会自动过期，除非你主动更新），步骤如下：

// 初始化Esper引擎实例
EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider();
EPAdministrator admin = epService.getEPAdministrator();

// 先注册刚才定义的两个事件类型
admin.getConfiguration().addEventType(ReferenceData.class);
admin.getConfiguration().addEventType(IncomingEvent.class);

// 1. 读取并解析文本文件内容
BufferedReader reader = new BufferedReader(new FileReader("你的文本文件路径.txt"));
String line;
while ((line = reader.readLine()) != null) {
    // 按空格分割每行，注意每行是"XYZ 120 ABC 200"这种成对格式，所以步长设为2
    String[] parts = line.trim().split("\\s+");
    for (int i = 0; i < parts.length; i += 2) {
        String code = parts[i];
        int value = Integer.parseInt(parts[i+1]);
        // 把解析出的每条数据发送成ReferenceData事件
        epService.getEPRuntime().sendEvent(new ReferenceData(code, value));
    }
}
reader.close();

// 2. 创建一个永久存储的窗口来保存参考数据
String createWindowStmt = "create window ReferenceDataWindow.win:keepall() as ReferenceData";
admin.createEPL(createWindowStmt);

// 3. 把刚才发送的ReferenceData事件插入到窗口中
String insertStmt = "insert into ReferenceDataWindow select * from ReferenceData";
admin.createEPL(insertStmt);

小提示：如果你的文本数据需要动态更新（比如文件内容变化时同步到Esper），可以监听文件变更事件，先删除窗口中对应code的旧数据，再插入新数据即可。

现在参考数据已经存在窗口里了，就可以通过EPL关联传入的IncomingEvent和窗口数据，满足条件时触发自定义操作。举几个常见场景的例子：

示例1：当事件值大于对应参考值时触发 #

// 关联事件与参考数据，当eventValue > 参考value时输出结果
select 
    ie.eventCode, ie.eventValue, rd.value as referenceValue
from 
    IncomingEvent#win:length(1) ie, 
    ReferenceDataWindow rd
where 
    ie.eventCode = rd.code 
    and ie.eventValue > rd.value

给这个EPL语句添加监听器，就能在满足条件时执行你的业务逻辑：

EPStatement stmt = admin.createEPL(上面的EPL语句);
stmt.addListener((newData, oldData) -> {
    // 这里写你要执行的操作，比如告警、调用业务接口等
    for (EventBean event : newData) {
        System.out.printf("触发条件：%s的事件值%d大于参考值%d%n", 
            event.get("eventCode"), event.get("eventValue"), event.get("referenceValue"));
    }
});

示例2：当事件的code不在参考数据中时触发（异常事件检测） #

select ie.eventCode, ie.eventValue
from IncomingEvent#win:length(1) ie
where not exists (select * from ReferenceDataWindow rd where rd.code = ie.eventCode)

最后可以发送几个测试事件来验证整个流程：

// 发送一个符合条件的事件（XYZ参考值是120，事件值150大于参考值）
epService.getEPRuntime().sendEvent(new IncomingEvent("XYZ", 150));
// 发送一个不符合条件的事件（ABC参考值是200，事件值180小于参考值）
epService.getEPRuntime().sendEvent(new IncomingEvent("ABC", 180));
// 发送一个不在参考数据中的事件
epService.getEPRuntime().sendEvent(new IncomingEvent("DEF", 100));

内容的提问来源于stack exchange，提问作者jocund