流分析-AMQP

2020-09-02 11:32发布

点击此处---> 群内免费提供SAP练习系统(在群公告中)加入QQ群:457200227(SAP S4 HANA技术交流) 群内免费提供SAP练习系统(在群公告中)嗨 有人有AMQP适配器在HA...

         点击此处--->   EasySAP.com群内免费提供SAP练习系统(在群公告中)

加入QQ群:457200227(SAP S4 HANA技术交流) 群内免费提供SAP练习系统(在群公告中)


有人有AMQP适配器在HANA Express上工作吗? 我在NUC上安装了新的Express服务器,并配置了环境以运行Streaming Analytics。 我做了一些准备工作,将一些数据发布到HANA表中。 我想扩展这个小演示,以通过AMQP适配器接收IOT数据。 我添加了AMQP输入适配器,但是无法启动它。 看来我需要调整适配器配置文件和其他一些文件。 任何人都可以使用它,并且可以分享一些有关如何启动和运行它的准则。

我还需要添加一个名为STREAMING_CUSTOM_ADAPTERS_HOME的环境变量,不确定我应该使用的文件夹,但是我已经在以下文件夹上进行了测试:/hana/shared/HXE/streaming-2_00_040_00_190304/STREAMING-2_0/adapters/framework/instances/amqp_string_input。

我在下面添加了一些错误消息:

org.xml.sax.SAXParseException; lineNumber:50; columnNumber:81; src-resolve:无法将名称" DefinedTypeParameters"解析为一个(n)"类型定义"组件。 org.apache.xerces.util.ErrorHandlerWrapper.createSAXParseException(未知源)org.apache.xerces.impl.XMLErrorReporter.reportError(未知源)org.apache.xerces.util.ErrorHandlerWrapper.error(未知源) org.apache.xerces.impl.xs.traversers.XSDHandler.reportSchemaError(未知源)的org.apache.xerces.impl.xs.traversers.XSDHandler.getGlobalDecl的.apache.xerces.impl.XMLErrorReporter.reportError(未知源) (未知来源)在org.apache.xerces.impl.xs.traversers.XSDElementTraverser.traverseNamedElement(未知来源)在org.apache.xerces.impl.xs.traversers.XSDElementTraverser.traverseLocal(未知来源)在org.apache.xerces org.apache.xerces.impl.xs.XMLSchemaLoader.loadSchema(Unknown处的.impl.xs.traversers.XSDHandler.traverseLocalElements(未知源) 来源)在org.apache.xerces.impl.xs.XMLSchemaLoader.loadGrammar(未知来源)在org.apache.xerces.impl.xs.XMLSchema org.apache.xerces.jaxp.validation.XMLSchemaFactory.newSchema(javax.xml.validation.SchemaFactory.newSchema(SchemaFactory.java:638)处的Loader.loadGrammar(未知源)在com.sybase.esp.adapter中 com.sybase.esp.adapter.framework.common.XmlUtils.loadFile(XmlUtils.java:54)的.framework.common.XmlUtils.loadSchema(XmlUtils.java:208)com.sybase.esp.adapter.framework.config com.sybase.esp.adapter.framework.config.AdapterConfig.load(AdapterConfig.java:1292)处的.ConfigBase.load(ConfigBase.java:45)在com.sybase.esp.adapter.framework.internal.Adapter.loadConfig中 (Adapter.java:72)在com.sybase.esp.adapter.framework.Framework.main(Framework.java:61)

4条回答
xfwsx85
2020-09-02 12:19

嗨,Petter,您可能无法访问此Hana Coldeline,我提供了一些AMOP适配器示例,如下所示:

1。 toolkit_amqp_csv_input

附加输入适配器AMQP_CSV_Input1类型toolkit_amqp_csv_input到BaseInput属性地址='varese.sjc.sap.corp',用户名='sybase',密码='sybase',加密= false,队列='queue_csv1',ClientName ='toolkit amqp csv输入适配器';

2。 toolkit_amqp_csv_output

附加输出适配器AMQP_CSV_Output1类型toolkit_amqp_csv_output至BaseOutput属性地址='varese.sjc.sap.corp',用户名='sybase',密码='sybase',加密= false,Exchange ='exchange_csv1',ExchangeType ='扇出 ',Queue ='queue_csv1',RouteKey ='queue_csv1',ClientName ='toolkit amqp csv输出适配器',BatchSize = 1,BatchPeriod = 0,Persistent = true,OutputBase = TRUE;

在这里,queue_csv1是在RabbitMQ服务器中创建的队列!

如果您有任何问题,请告诉我。

谢谢

一周热门 更多>