我试着把我的气流和Cassandradb连接起来。到目前为止,我已经明白Cassandra连接应该出来的盒子气流,没有必要安装一个外部驱动程序,如甲骨文。
唯一相关的信息,我发现是气流提供的以下链接,但对我帮助不大:https://airflow.readthedocs.io/en/latest/_api/airflow/providers/apache/cassandra/hooks/cassandra/index.html
我的cassandra连接设置如下: Conn Type: Cassandra
Host: myHost1,myHost2 Login: myUser
Password: myPass Port: 9042
cassandra连接设置
在我定义的“extras”中,连接应该使用dcawarerroundrobinpolicy作为负载平衡策略。
当我尝试使用以下测试查询使用气流数据分析选项卡中的特别查询选项测试连接时 SELECT now() FROM system.local;
,我没有收到任何错误消息,在气流日志中也没有异常或警告。我得到的唯一ui响应是“无数据”,但应该有一些数据(我还测试了其他查询,其中也应该返回一些数据,但每次的响应都是相同的“无数据”)Cassandra特设查询
airflow正在成功连接到oracle,这就是为什么我不认为问题出在网络上。我的气流示例也使用localexecutor。
你知道吗,我错过了什么,我该如何与Cassandra建立成功的联系?
谢谢!
暂无答案!
目前还没有任何答案,快来回答吧!