pyflink连接sqlserver，flink sql客户端

怎么在java的flink中调用python程序?

查阅了一些网上资料，看到了很多介绍使用jython调用python代码的例子，不过由于一些原因我没有尝试这个方法，而是直接测试了Runtime.getRuntime().exec(args)这个java库中自带的方法，下面直接切入主题。

不建议研究jython。比较简单的思路是把python脚本完全当做一个外部程序，用shell方式调用它。首先设计好python脚本的接口，把参数用命令行方式传入，然后输出打印出来。示例：python func.py arg1 arg2 result 然后在java里就可以用Runtime来执行shell命令，解析输出字符串然后得到结果。

如果是jython，也就是运行在Jvm上的python的话，可以使用JSR223，JDK6已经包含了该扩展包。JSR223是一个用于解析多种脚本语言的库包，其中包括Jython。除了JSR223包之外，还需要jython-engine.jar包。

因为你调用的test_tiger.py需要加载python里面的module，而java调用的时候这里的py脚本的模块都要加到python的环境变量里面。

很久以前用eclipse写过python，好像要用插件的。 另外结合引用jar包的经验，引用一个jar包的时候要把该jar包的依赖包也引入 你这个看上去是缺少os这个模块。

相关问答

Q1: pyflink消费kafka-connect-jdbc消息(带schema)

1、Flink 中的 Jar 包是 connector 的扩展，允许在 flink 脚本中连接和使用各种数据存储工具，包括：Pyflink 默认支持有限的几种 jar 包，如有特殊需要（例如以 json 格式来消费 kafka 里的数据），需要手动指定脚本依赖的 jar 包所在的路径。已知有 3 种方式来指定 jar 包依赖。

2、Apache ActiveMQ：实现JMS的开源消息代理(broker)，可将同步通讯转为异步通讯。官网 Apache Camel：通过企业级整合模式(Enterprise Integration Pattern EIP)将不同的消息传输API整合在一起。官网 Apache Kafka：高吞吐量分布式消息系统。官网 Hermes：快速、可靠的消息代理(Broker)，基于Kafka构建。

关于pyflink连接sqlserver和flink sql客户端的介绍到此就结束了，不知道你从中找到你需要的信息了吗 ？如果你还想了解更多这方面的信息，记得收藏关注本站。