oracle 导入 kafka 用什么etl

答案:2 悬赏:80 手机版

解决时间 2021-04-07 20:24

提问者网友：疯子也有疯子的情调
2021-04-07 11:24

最佳答案

五星知识达人网友：等灯
2021-04-07 12:03

可以用PyMySQL代替。安装方法：pip install PyMySQL
然后在需要的项目中，把 __init__.py中添加两行：
import pymysql
pymysql.install_as_MySQLdb()
就可以用 import MySQLdb了。其他的方法与MySQLdb一样。

全部回答

1楼网友：一把行者刀
2021-04-07 13:13

kafka是由linkedin设计的一个高吞吐量、分布式、基于发布订阅模式的消息系统，使用scala编写，它以可水平扩展、可靠性、异步通信和高吞吐率等特性而被广泛使用。目前越来越多的开源分布式处理系统都支持与kafka集成，其中spark streaming作为后端流引擎配合kafka作为前端消息系统正成为当前流处理系统的主流架构之一。然而，当下越来越多的安全漏洞、数据泄露等问题的爆发，安全正成为系统选型不得不考虑的问题，kafka由于其安全机制的匮乏，也导致其在数据敏感行业的部署存在严重的安全隐患。本文将围绕kafka，先介绍其整体架构和关键概念，再深入分析其架构之中存在的安全问题，最后分享下transwarp在kafka安全性上所做的工作及其使用方法。

我要举报

如以上回答内容为低俗、色情、不良、暴力、侵权、涉及违法等信息，可以点下面链接进行举报！

点此我要举报以上问答信息