点击此处--->
群内免费提供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）
{var%20f='http://v.t.sina.com.cn/share/share.php?appkey=1515056452',u=z||d.location,p=['&url=',e(u),'&title=',e(t||d.title),'&source=',e(r),'&sourceUrl=',e(l),'&content=',c||'gb2312','&pic=',e(p||'')].join('');function%20a(){if(!window.open([f,p].join(''),'mb',['toolbar=0,status=0,resizable=1,width=440,height=430,left=',(s.width-440)/2,',top=',(s.height-430)/2].join('')))u.href=[f,p].join('');};if(/Firefox/.test(navigator.userAgent))setTimeout(a,0);else%20a();})(screen,document,encodeURIComponent,'','','http://www.easysap.com/data/attach/logo/logo.png', '推荐 南山jay 的问题《流分析-AMQP》','https://www.easysap.com/q-48743.html','页面编码gb2312|utf-8默认gb2312'));){kind=link}
嗨，Petter，在流式屏障测试期间，流式AMQP适配器每天运行很多时间。 如果可以访问hana代码行，则可以在git/hana/nutest/testscripts/hstreaming/models/TestToolkitAdapterAMQP下获得这些测试用例（CCL）。 您可以参考那些CCL，然后您应该知道如何实现AMQP适配器。
远程RabbitMQ服务器位于varese.sjc.sap.corp中。 对于AMQP barries测试，它使用AMQP适配器运行项目，以使用varese.sjc.sap.corp中的RabbitMQ服务器进行输入/输出操作。
对于STREAMING_CUSTOM_ADAPTERS_HOME设置，请参考以下URL：
https .sap.com/viewer/34b97bb51d324fe3ace65b3102e453cd/1.0.12/zh-CN/d3dd6e3e7d6e4111a239259e20c130fa.html？q =％20STREAMING_CUSTOM_ADAPTERS_HOME
在我的SDS环境中，它是/usr/sap/T00/HDB00/streaming/cluster/t00/adapters
让我知道您是否仍然有运行AMQP适配器的问题。
最好将CCL发送给我看看。
谢谢
Lin
嗨，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服务器中创建的队列！
如果您有任何问题，请告诉我。
谢谢
林
你好林
感谢您的回答，我将对此进行研究，并尝试弄清楚如何运行适配器并发布一些AMQP消息。
这是正确的安装/设置步骤吗？
1）使用流分析安装HANA
2）配置AMQP适配器（通过更新一些配置文件）
3）确保所有环境变量均已正确设置
（回显'export STREAMING_CUSTOM_ADAPTERS_HOME ="/img/hana/shared/HXE/streaming/STREAMING-2_0/adapters/framework"'>> $ HOME/.customer.sh）
4）使用AMQP适配器构建新的streeam，并确保它已发布且AMQP适配器正在运行
5）连接到AMQP适配器（具有正确的端口号），并使用f.eks RabbitMQ发布一些消息。
修复变量后，尝试使用以下命令启动适配器 命令start_adapter.sh我收到错误消息：配置文件无效：
当我针对framework.xsd在adapter_config.xml上运行模式测试时，出现一条错误消息：Src-resolve：无法将名称'DefinedTypeParameters'解析为A（n）'类型定义'组件。
我似乎在framework.xsd中的这一行引起了问题：
关于此的任何想法，我是否需要使用一些值更新adapter_config.xml？
一周热门 更多>