Facebook聊天機器人多次發送相同的消息（Python）

Question

我正在facebook迷你聊天機器人上工作，我遇到一個問題，它包含了機器人一遍又一遍地接收相同的消息，即使它已經回答了信息。

it keeps receiving the same text from FB and replying to it over and over

def message_handler(request): 
    data = json.loads(request.body.decode('utf-8')) 

    if data and data['object'] == 'page': 
     for pageEntry in data['entry']: 
      print "nombre de message", len(pageEntry['messaging']) 
      for messagingEvent in pageEntry['messaging']: 

       if messagingEvent.get('optin'): 
        print "optin", messagingEvent 
        receivedAuthentication(messagingEvent) 
       elif messagingEvent.get('message'): 
        print "message", messagingEvent 
        receivedMessage(messagingEvent) 
       elif messagingEvent.get('delivery'): 
        print "delivery", messagingEvent 
        receivedDeliveryConfirmation(messagingEvent) 
       elif messagingEvent.get('postback'): 
        print "postback", messagingEvent 
        receivedPostback(messagingEvent) 
       else: 
        print "UnHandled" 
    return HttpResponse(status=200) 

def receivedMessage(event): 
    senderID = event.get('sender').get('id') 
    message = event.get('message') 

    messageText = message.get('text') 
    messageAttachments = message.get('attachments') 

    if messageText: 
     if messageText == 'image': 
      sendImageMessage(senderID) 

     elif messageText == 'button': 
      sendButtonMessage(senderID) 

     elif messageText == 'generic': 
      sendGenericMessage(senderID) 

     elif messageText == 'receipt': 
      sendReceiptMessage(senderID) 
     elif messageText == 'hey': 
      sendTextMessage(senderID, "Get it. Gimme a moment to process it :). Will get back to you in a moment") 
      send_seen() 
      send_typing() 
      words = words_gen() 
      sendTextMessage(senderID, words) 


def callSendAPI(messageData): 
    requests.post(
      url='https://graph.facebook.com/v2.6/me/messages?access_token=' + config.page_token, 
      data=json.dumps(messageData), 
     headers={"Content-Type":"application/json"} 
    ) 

，我感到我需要發送的每一次狀態200，我做到了，但在仍收到相同的文字和超過

這裏是我訂閱的

事件

對話，message_deliveries，message_reads，messages，messaging_optins，messaging_postbacks，圖片

我刪除messaging_echoes，因爲我認爲這是問題，通過寫一個函數，並檢查我的Web API服務重複消息橫空出世，不

Answer 1

我已經解決了這個問題。

在這裏，我通過有效載荷或從Facebook接收的消息生成消息唯一標識，用戶單擊或鍵入，然後與併發字典中較早存儲的唯一值進行比較。

_messageUniqueKeysBySender是ConcurrentDictionary，我用發件人ID緩存值30分鐘。

private bool IsDuplicate(Messaging messaging) 
    { 
     var messageUniqueId = string.Empty; 
     var messageMessaging = messaging as MessageMessaging; 
     if (messageMessaging != null) 
      messageUniqueId = messageMessaging.Message.Id + messageMessaging.Message.SequenceNumber; 
     else if (messaging is PostbackMessaging) 
      messageUniqueId = ((PostbackMessaging)messaging).Postback.Payload + 
           ((PostbackMessaging)messaging).TimestampUnix; 
     if (string.IsNullOrEmpty(messageUniqueId)) return false; 
     string existingUniqueId; 
     if (_messageUniqueKeysBySender.TryGetValue(messaging.Sender.Id, out existingUniqueId)) 
     { 
      if (existingUniqueId == messageUniqueId) 
      { 
       return true; 
      } 
      else 
      { 
       _messageUniqueKeysBySender.TryUpdate(messaging.Sender.Id, messageUniqueId, existingUniqueId); 
       return false; 
      } 
     } 
     _messageUniqueKeysBySender.TryAdd(messaging.Sender.Id, messageUniqueId); 
     return false; 
    } 

然後在主代碼

try 
     { 
      if (!IsDuplicate(messaging)) 
      { 
       var conversation = _conversationRepository[messaging.Sender.Id] ?? new Conversation(messaging.Sender.Id); 
       message = await _bot.RespondToMessagingAsync(conversation, messaging); 
       _conversationRepository[messaging.Sender.Id] = conversation; 
       _logger.ForContext("FacebookMessage", messagingJson).LogDuration("Processing Facebook message", sw); 
      } 
      else 
       _logger.ForContext("FacebookMessage", messagingJson).Warning("Duplicate message skipped"); 
     } 
     catch (Exception ex) 
     { 
      _logger.ForContext("FacebookMessage", messagingJson).Error(ex, "Failed to process message"); 
      message = new TextMessage(Resources.Error); 
      hasError = true; 
     }