如何让apache pig连接到需要身份验证的mongodb

mm5n2pyu  于 2021-06-21  发布在  Pig
关注(0)|答案(1)|浏览(448)

这是关于如何从mongodb读取或插入pig的文档:https://github.com/mongodb/mongo-hadoop/wiki/pig-usage
但是本指南没有说明如何连接到需要身份验证的mongodb。有人能帮我吗?;)。

hwamh0ep

hwamh0ep1#

我找到路了。这是mongodb站点中的指南:https://docs.mongodb.org/manual/reference/connection-string/
如果出现错误:

org.apache.pig.backend.executionengine.ExecException: ERROR 2118: Unable to calculate input splits: unauthorized

然后阅读以下指南:

https://groups.google.com/forum/#!topic/mongodb-user/iWRGA_HKQDM
https://groups.google.com/forum/#!msg/mongodb-user/wKTPri2rnSk/BCdaOgCAWNUJ

这是我的剧本:

mongo_data = LOAD 'mongodb://username:password@xxx.xxx.xxx.xxx:27017/test.test_1?authSource=admin' USING com.mongodb.hadoop.pig.MongoLoader(...);

相关问题