使用spring-xd中的分析模块创建流失败(stream creation with analytic module in spring-xd get failed)
我正在研究spring-xd框架。 我正在关注Spring-XD guide Analytic选项卡,并希望为直播数据部署我的预测模型。
我已经使用R中的naive-Bayes构建了虹膜分类模型,并将该pmml文件存储在桌面上的Ubuntu-14.0.4 Lts中。 这是我的流定义 -
stream create test --definition "mqtt --url='tcp://localhost:1883' --topics='irisPayload'| analytic-pmml --location='/home/andy/Desktop/iris-flower-naive-bayes.pmml.xml' --inputFieldMapping='sepalLength:Sepal.Length,sepalWidth:Sepal.Width,petalLength:Petal.Length,petalWidth:Petal.Width'--outputFieldMapping='Predicted_Species:predictedSpecies' | file" --deploy .
错误: - 找不到分析和处理器模块。
我认为我的流定义是错误的。 因为我无法在spring-xd指南中为这种情况找到流定义。
我在本地机器的单节点上运行spring-xd。 我想用MQTT Pub-Sub协议发送我的数据,而不是Http。 我的MQTT经纪人已经启动并运行了,任何形式的帮助都是值得赞赏的。 非常感谢。
I am working on spring-xd framework. I am following Spring-XD guide Analytic tab and want to deploy my prediction model for live streaming data.
I have built the iris classification model using naive-Bayes in R and store that pmml file at my desktop in Ubuntu-14.0.4 Lts. this is my stream definition-
stream create test --definition "mqtt --url='tcp://localhost:1883' --topics='irisPayload'| analytic-pmml --location='/home/andy/Desktop/iris-flower-naive-bayes.pmml.xml' --inputFieldMapping='sepalLength:Sepal.Length,sepalWidth:Sepal.Width,petalLength:Petal.Length,petalWidth:Petal.Width'--outputFieldMapping='Predicted_Species:predictedSpecies' | file" --deploy .
Error:- Analytic and processor module is not found.
I Think my stream definition is wrong. as I am unable to found stream definition for such a case in spring-xd guide.
I am running spring-xd in single-node at my local machine. Instead of Http, I want to send my data using MQTT Pub-Sub protocol. my MQTT broker is up and running, any sort of help is appreciated. thanks a lot.
原文:https://stackoverflow.com/questions/42688938
最满意答案
正确。 Mail API尚不支持批处理。
Correct. The Mail API doesn't support batching yet.
相关问答
更多-
Office 365 REST API(Office 365 REST API)[2023-10-16]
您可以使用用户的电子邮件/密码来检索OAuth令牌。 但是,您仍需要注册您的应用程序以获取客户端ID。 本机应用程序(如Windows应用程序)不使用客户端密钥。 看一下.NET的ADAL库 。 AcquireTokenAsync的重载AcquireTokenAsync是UserCredential对象。 REST API没有任何与委托一起使用的功能。 您可以使用Exchange Web服务与代理一起使用。 You can use the user's email/password to retrieve ... -
每个将使用我的应用程序的办公室帐户必须在Microsoft azure上执行一些配置步骤。 得到秘密密钥,客户端和租户id。 如果我正确理解您的问题,您是否要避免为app用户配置client_id,密钥的所有步骤? 如果您的应用程序是基于浏览器的Web应用程序,则图表上的“应用程序”块实际上包含Web服务器和用户/浏览器。 在这种情况下,只有Web服务器需要从Azure,client_id,secrect等中提取配置......这就是说,用户/ Web浏览器只需要输入他的凭证,并且在默认情况下,您的应用程序 ...
-
根据提供的信息,Exchange Web服务将是您的唯一选择。 当前用于REST API的移动和复制的范围在单个邮箱中。 Based on the info provided, Exchange Web Services would be the only option for you. The scope of a move and copy currently for our REST API is within a single mailbox.
-
目前,REST API不支持联系照片或用户个人资料照片。 我们正在努力尽快补充。 请留意我们的博客或关注@JasonJohMSFT)关于新功能的公告。 更新:用户照片API现在处于预览状态: https : //msdn.microsoft.com/office/office365/APi/photo-rest-operations Right now, the REST APIs don't support contact photos or user profile photos. We're work ...
-
我在这里找到了答案: 从用户的主日历(../me/events) 或从其他日历获取系列主事件和单实例事件的集合。 GET https://outlook.office.com/api/v2.0/me/calendars/ {calendar_id} / events 其中{calendar_id}是您希望访问的日历的ID。 你可以在这个答案中找到如何获取ID。 有用。 I found the answer here: Get a collection of series master and single ...
-
如上所述,我们可以使用以下API调用: GET扩展=附件($ expand = Microsoft.OutlookServices.ItemAttachment / Item($ expand = Microsoft.OutlookServices.Event /附件)) As mentioned here, we can use the following api call: GET https://outlook.office.com/api/beta/me/messages/[message-id]? ...
-
在office 365 email rest api中进行批量请求(Doing batch requests in the office 365 email rest api)[2022-08-29]
正确。 Mail API尚不支持批处理。 Correct. The Mail API doesn't support batching yet. -
更新: InternetMessageHeaders属性已添加到Outlook API的测试版端点,因此您可以在不使用扩展属性的情况下获取此信息。 你必须通过$select显式请求属性。 就像是: GET https://outlook.office.com/api/beta/me/mailfolders/inbox/messages? $select=Subject,InternetMessageHeaders 对于Graph:此属性也存在于Graph的beta端点中的消息中,因此您可以执行以下操作: ...
-
更新: /beta端点上的Message上现在有一个Flag属性。 这是推荐的方法。 我会将其他信息留作历史用途,并帮助人们尝试设置其他扩展属性。 现在你可以更容易地获得/设置标志状态。 Message实体现在具有类型FollowupFlag的Flag属性。 (如果您没有在该链接看到它,请确保在页面顶部选择beta版)。 您可以通过发送带有以下有效负载的PATCH将标记为标记的消息: { "Flag": { "FlagStatus": "Flagged" } } 旧方法(使用扩展属性) 注 ...
-
用/users/
替换URL的/me位。 您不能使用/me进行任何带有来自客户端凭据的令牌的API调用。 Replace the /me bit of the URL with /users/ . You can not use /me for any API call with a token from client credentials.