(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210950014.4 (22)申请日 2022.08.09 (71)申请人 杭州玳数 科技有限公司 地址 310000 浙江省杭州市余杭区仓前街 道余杭塘路2301号海智中心8幢102 室-5 (72)发明人 王鲁宁　 (74)专利代理 机构 杭州裕阳联合专利代理有限 公司 33289 专利代理师 杨琪宇 (51)Int.Cl. G06F 16/25(2019.01) G06F 16/2455(2019.01) G06F 8/30(2018.01) (54)发明名称 一种基于Python Flink的Pulsar连接器实 现方法及系统 (57)摘要 本申请公开了一种基于Python  Flink的 Pulsar连接器实现方法及系统， 涉及数据传输技 术领域， 包括以下步骤： 根据Flink系统中Java的 Pulsar连接器数据流接口类在Python  Flink源 代码文件中新建Python的Pulsar连接器数据流 接口类； 通过Py4J中的JavaGateway调用Java接 口类方法以实现对应的Pyt hon接口类方法； 将编 写的代码安装到Python环境中， 并利用Pyt hon编 写读取或写入Pulsar消息系统的程序逻辑以读 写Pulsar消息系统中的数据。 本申请使操作人员 可以利用Pyt hon语言去操作Flink读 写Pulsar中 的数据， 方便了纯Python操作人员的工作， 且不 会因为使用Pyt hon语言而损耗更多的系统性能， 并相较于现有调用接口， 提供了更 大的灵活性。 权利要求书2页 说明书6页 附图1页 CN 115269707 A 2022.11.01 CN 115269707 A 1.一种基于Pytho n Flink的Pulsar连接器实现方法， 其特 征在于， 包括以下步骤： 根据Flink系统中Java 的Pulsar连接器数据流接口类在Python  Flink源代码文件中新 建Python的Pulsar连接器数据流接口类； 通过Py4J中的JavaGateway调用Java接口类方法以实现对应的Pytho n接口类方法； 将编写的代码安装到P ython环境 中， 并利用P ython编写读取或写入Pulsar消息系统的 程序逻辑以读写Pulsar消息系统中的数据。 2.根据权利要求1所述的一种基于Python  Flink的Pulsar连接器实现方法， 其特征在 于， 所述根据Flink系统中Jav a的Pulsar连接器数据流接口类在Python  Flink源代码文件 中新建Pytho n的Pulsar连接器数据流接口类， 包括： 确定Flink系统中Java读写Pulsar消息系统数据的全部接 口类， 所述接口类包含读取 类和写入类； 在Python  Flink源代码文件中新建与Java接口类名称相同且一一对应的Python的 Pulsar连接器数据流接口类。 3.根据权利要求1所述的一种基于Python  Flink的Pulsar连接器实现方法， 其特征在 于， 所述通过Py4J中的JavaGateway调用Java接口类方法以实现对应的Python接口类方法， 包括： 使用Py4J的JavaGateway工具类实例化Python接口类的构造方法对应的Java接口类， 并将实例化的Java接口类对象保存在相应的Pytho n接口类属性中。 4.根据权利要求3所述的一种基于Python  Flink的Pulsar连接器实现方法， 其特征在 于， 所述通过Py4J中的JavaGateway调用Java接口类方法以实现对应的Python接口类方法， 还包括： 将每个Python接口类中除构造方法外的所有方法的参数格式设置为与对应的Java接 口类方法参数格式相同。 5.根据权利要求4所述的一种基于Python  Flink的Pulsar连接器实现方法， 其特征在 于， 所述通过Py4J中的JavaGateway调用Java接口类方法以实现对应的Python接口类方法， 还包括： 为每个Python接口类新建空方法， 并令其方法的参数个数和参数类型与对应的Java接 口类方法参数一 致， 所述空方法不 为构造方法； 根据保存的Java接口类对象， 在Pytho n方法中调用对应的Java接口类方法。 6.根据权利要求5所述的一种基于Python  Flink的Pulsar连接器实现方法， 其特征在 于， 所述根据保存的Java接口类对象， 在Pytho n方法中调用对应的Java接口类方法， 包括： 将Python接口类方法的参数传递给Pytho n接口类属性中持有的Java对象对应的方法。 7.根据权利要求1所述的一种基于Python  Flink的Pulsar连接器实现方法， 其特征在 于， 所述利用Python编写读取或写入Pulsar消息系统的程序逻辑以读写Pulsar消息系统中 的数据之前还 包括： 使用Pytho n包模块导入机制将编写的代码导入到用户当前程序所在的文件中。 8.一种基于Pytho n Flink的Pulsar连接器实现系统， 其特 征在于， 包括： 新建模块， 用于根据Flink系统中Java的Pulsar连接器数据流接口类在Python  Flink 源代码文件中新建Pytho n的Pulsar连接器数据流接口类；权　利　要　求　书 1/2 页 2 CN 115269707 A 2调用模块， 用于通过Py4J中的JavaGateway调用Java接口类方法以实现对应的Python 接口类方法； 导入模块， 用于将编写的代码安装到Python环境中， 并利用Python编写读取或写入 Pulsar消息系统的程序逻辑以读写Pulsar消息系统中的数据。 9.一种电子设备， 其特征在于， 包括存储器和处理器， 所述存储器用于存储一条或多条 计算机指令， 其中， 所述一条或多条计算机指令被所述处理器执行以实现如权利要求1～7 中任一项所述的一种基于Pytho n Flink的Pulsar连接器实现方法。 10.一种存储有计算机程序的计算机可读存储介质， 其特征在于， 所述计算机程序使计 算机执行时实现如权利要求1～7中任一项所述的一种 基于Python  Flink的Pulsar连接器 实现方法。权　利　要　求　书 2/2 页 3 CN 115269707 A 3