我正在尝试为我的微软机器人在webapi中实现自定义连接器,以便可以通过Rest API从不同的应用程序调用它(对于exmp: from rasberripy).The意图是在WebAPI中使用directline API实现自定义连接器,以便其他应用程序可以使用rest调用来与此API对话,这反过来将使用dirtectline API与我的机器人对话。我测试了下面的code from micrososft,它在一个控制台应用程序中工作。我已经将相同的代码移到了WebAPI,在这里相同的代码表现不同。
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.Mvc;
using System.Threading.Tasks;
using Microsoft.Bot.Connector.DirectLine;
using Newtonsoft.Json;
using System.Configuration;
namespace BotConnector.Web.Controllers
{
public class BotController : Controller
{
private static string directLineSecret = ConfigurationManager.AppSettings["DirectLineSecret"];
private static string botId = ConfigurationManager.AppSettings["BotId"];
private static string fromUser = "APISampleClientUser";
// GET: Bot
public ActionResult Index()
{
return View();
}
public string Connect()
{
var conversation=StartBotConversation();
return conversation.ConversationId;
}
public string ReadBotMessages(string conversationId,string message)
{
//DirectLineClient client = (Session["client"] == null) ? new DirectLineClient(directLineSecret) : Session["client"] as DirectLineClient;
//Session["client"] = client;
DirectLineClient client = new DirectLineClient(directLineSecret);
var activity = new Activity
{
From = new ChannelAccount(fromUser),
Text = message,
Type = ActivityTypes.Message
};
client.Conversations.PostActivityAsync(conversationId, activity);
var response = ReadBotMessagesAsync(client, conversationId);
//var heroCard = JsonConvert.DeserializeObject<HeroCard>(response[0].Content.ToString());
return response.Result;
}
private static Conversation StartBotConversation()
{
//var session = System.Web.HttpContext.Current.Session["client"];
//DirectLineClient client = (session == null) ? new DirectLineClient(directLineSecret) : session as DirectLineClient;
//System.Web.HttpContext.Current.Session["client"] = client;
var client = new DirectLineClient(directLineSecret);
var conversation = client.Conversations.StartConversationAsync().Result;
//new System.Threading.Thread(async () => await ReadBotMessagesAsync(client, conversation.ConversationId)).Start();
return conversation;
}
private static async Task<string> ReadBotMessagesAsync(DirectLineClient client, string conversationId)
{
string watermark = null;
var attachments = new List<Attachment>();
string message = string.Empty;
while (true)
{
var activitySet = client.Conversations.GetActivities(conversationId, watermark);
watermark = activitySet?.Watermark;
var activities = from x in activitySet.Activities
where x.From.Id == botId
select x;
foreach (Activity activity in activities)
{
message = activity.Text;
if (activity.Attachments != null)
{
foreach (Attachment attachment in activity.Attachments)
{
if (attachment.ContentType== "application/vnd.microsoft.card.hero")
{
var heroCard = JsonConvert.DeserializeObject<HeroCard>(attachment.Content.ToString());
message = heroCard.Text;
//attachments.Add(attachment);
}
}
}
}
//if (attachments.Count > 0) break;
if (!string.IsNullOrEmpty(message)) break;
//await Task.Delay(TimeSpan.FromSeconds(1)).ConfigureAwait(false);
}
return message;
}
}
}
首先,我将调用Bot/Connect来生成问题,随后我将使用Id和conversationId - later调用Bot/ReadBotMessages。
我面临的问题是代码
var activitySet = client.Conversations.GetActivities(conversationId, watermark);
在每次命中时都会返回多个活动,还会返回之前问题的响应(
),但我应该得到与当前响应相关的单个活动,相同的逻辑在github的控制台应用程序中工作得很好,它只返回一个当前活动。有没有人能给我一个变通的建议,或者我在做什么?
发布于 2018-06-06 03:52:56
为了只获取最新的活动,您需要确保将当前水印存储在连接器中的某个位置。
调用以下方法:
Client.Conversations.PostActivityAsync(conversationId, activity);
将返回一个格式如下的字符串:
"IRBO9ZhxkwID1QnNbAoOHX|0000008"
即
"{ConversationId|Watermark}"
您需要将此调用的水印部分保存在连接器中的某个位置,因为稍后在连接器的消息接收调用中使用它将只允许您获得对消息的即时响应:
private static async Task<string> ReadBotMessagesAsync(DirectLineClient client, string conversationId)
{
string watermark = null; //this should be the current watermark
基本上,会话的端点获取调用:
/v3/directline/conversations/{conversationID}/activities?watermark={watermark}
返回bot存储的会话,从"watermark“开始,如果设置为null,则返回bot内存中可用会话的一部分,从bot与bot进行reconnecting之前发送的最后一条消息开始(这就是您看到的内容)。
https://stackoverflow.com/questions/50703476
复制相似问题