架构如下:
jms->kafka->spark->hbase
它们是从jms到hbase的数据流(xml)。
我的要求:
我可以使用时间戳实现各种大小数据的基准测试。(完成)
负载测试相同的场景?如何在loadrunner的帮助下实现整个事务的响应时间(数据到达hbase时的响应时间)?
下面是在jms队列上生成加载的代码:
Action() {
jms_publish_message_topic("SendMessage",
"hello {NewParam_2}",
"sampletopic");
jms_publish_message_topic("sendXml",
"<?xml version=\"1.0\" encoding=\"UTF-8\"?>\r\n<ns0:NotificaCollezioneTessile "
"xmlns:ns0=\"http://carrefour.it/mdg/schemas/xsd\">\r\n <ns0:Infolog>\r\n "
" <ns0:TimeStamp>{NewParam_7}</ns0:TimeStamp>\r\n "
"</ns0:Infolog>\r\n <ns0:Context>\r\n <ns0:ContextId>"
"ASTRA-ACCTB-VL-FIRST</ns0:ContextId>\r\n </ns0:Context>\r\n "
"<ns0:CollezioneTessile>\r\n <ns0:Anagrafica>\r\n <ns0:Anno>"
"2017</ns0:Anno>\r\n <ns0:CollezioneTessileDx>"
"CONTINUATIVO</ns0:CollezioneTessileDx>\r\n "
"<ns0:CollezioneTessileTipoCod>CO</ns0:CollezioneTessileTipoCod>\r\n "
"<ns0:DtImpianto>2017-07-10</ns0:DtImpianto>\r\n <ns0:FDeMarca>"
"false</ns0:FDeMarca>\r\n <ns0:DtDec>2017-07-07+02:00</ns0:DtDec>\r\n "
" <ns0:DtCes>2017-10-01</ns0:DtCes>\r\n </ns0:Anagrafica>\r\n "
" <ns0:AlberoPrincipale>\r\n <ns0:RepCod>60</ns0:RepCod>\r\n "
" </ns0:AlberoPrincipale>\r\n </ns0:CollezioneTessile>"
"\r\n</ns0:NotificaCollezioneTessile>",
"fornitore");
return 0;
}
我将参数化xml数据,并为每次运行发送当前时间戳。
请提出实现端到端响应时间的建议?
暂无答案!
目前还没有任何答案,快来回答吧!