MongoDBInput Java集成

Question

我有一个简单的五旬节格式，MongoDBInput与JSON输出连接。我可以在宾得设计工作室看到预览版时获取json，但是当我尝试与java集成并运行转换时，它的抛出错误-

线程“主”org.pentaho.di.core.exception.KettleXMLException:错误从XML文件读取对象中的异常 无法从XML nodeorg.pentaho.di.core.exception.KettleStepLoaderException:加载step信息，无法为带有id MongoDbInput的step /插件加载类。检查插件是否在Kettle发行版的plugins子目录中可用。 无法加载id MongoDbInput的step/插件类。检查插件是否在Kettle发行版的plugins子目录中可用。

我的代码是：

 import java.io.IOException;
import java.util.List;
import org.pentaho.di.core.KettleEnvironment;
import org.pentaho.di.core.util.EnvUtil;
import org.pentaho.di.trans.TransMeta;
import org.pentaho.di.trans.Trans;
import org.pentaho.di.core.*;
import org.pentaho.di.core.exception.*;

public class KettleConnector {

    public static void main(String[] args) throws KettleException, IOException{

        KettleEnvironment.init(false);

        EnvUtil.environmentInit();

        TransMeta transMeta = new TransMeta("D:\\mangoes.ktr");

        Trans trans = new Trans(transMeta);

        trans.execute(null); // You can pass arguments instead of null.

        trans.waitUntilFinished();

        Result r = trans.getResult();

        List<RowMetaAndData> rowsResult = r.getRows();
        System.out.println(trans.getTransMeta());

        if (trans.getErrors() > 0) {

        throw new RuntimeException();

        }

    }

}

它适用于mysql转换。

我包括了mongo-2.4jar和mongo-java-驱动程序-2.7.2.jar。

仍然面临着这个错误。

Answer 1

请检查是否在运行时添加VM参数：

-DKETTLE_PLUGIN_BASE_FOLDERS=D:/LOCATION/data-integration/plugins

Answer 2

MongoDB步骤是五旬节数据集成插件。你用的是什么版本的PDI？如果您使用的是4.4.0，那么您将需要大数据插件，它包含MongoDB步骤。从启动应用程序的地方开始，您将需要一个插件/步骤文件夹，其中包含大数据插件(宾得-大数据-插件文件夹)的内容。然后，您对KettleEnvironment.init()的调用将加载插件，您将可以访问MongoDB步骤。

Answer 3

马特.我用五旬节水壶5.1。需要从插件文件夹中包含哪些jars才能使Mongodb步骤正常工作。我包括了所有的插件/五旬节-mongodb插件？

仍然得到相同的错误