偏移Azure中EventHubTrigger功能应用

后市展望： 使用与当一个新的事件在正在添加EventHubTrigger-CSHARP模板运行的功能应用偏移Azure中EventHubTrigger功能应用

实现： 运用https://azure.microsoft.com/en-us/documentation/articles/functions-bindings-event-hubs/

非常基本的例子

结果： 的解释方法：

public static void Run(string myEventHubMessage, TraceWriter log) 
{ 
    log.Info($"C# Event Hub trigger function processed a message: {myEventHubMessage}"); 
}

确实在事件队列中提供了“第一个”而不是当前的队列。

附加： - 我添加了一个consumerGroup（所以不从$默认阅读） - 根据此博客：http://www.yourcloudbuddy.com/2016/04/azure-functions-and-event-hubs.html“目前还没有办法将其配置为启动特定偏移”。

问题： 如何在我的功能应用程序中接收集线器上的最新事件？

更多信息： 我需要从事件中心新的信号转发到外部MQTT API（到目前为止的作品）。可能我需要另一种方法？

感谢名单对于任何输入，拉敏

来源

2016-10-27 Ramin

@Ramin到文件的功能要求，我试图重新与你相似的场景，但不能摄制的问题。以下是具体步骤：

设置事件枢纽触发功能（使用最新版本为0.7的2016年10月27日）
设置一个简单的控制台应用程序发送者发送10我的活动中心带时间戳和消息ID的消息。每条消息发送相隔6分钟。下面是输出为我的控制台应用程序，将记录发送的消息，

Sent message: Timestamp: 10/27/2016 2:27:06 PM, MessageId: 1 
Sent message: Timestamp: 10/27/2016 2:33:07 PM, MessageId: 2 
Sent message: Timestamp: 10/27/2016 2:39:07 PM, MessageId: 3 
Sent message: Timestamp: 10/27/2016 2:45:07 PM, MessageId: 4 
Sent message: Timestamp: 10/27/2016 2:51:08 PM, MessageId: 5 
Sent message: Timestamp: 10/27/2016 2:57:08 PM, MessageId: 6 
Sent message: Timestamp: 10/27/2016 3:03:08 PM, MessageId: 7 
Sent message: Timestamp: 10/27/2016 3:09:08 PM, MessageId: 8 
Sent message: Timestamp: 10/27/2016 3:15:08 PM, MessageId: 9 
Sent message: Timestamp: 10/27/2016 3:21:08 PM, MessageId: 10 
Stopped sending messages.

这里是我的职责，日志条目，

2016-10-27T21:27:26.516 Function started (Id=d5ed0e23-2b0e-4e0b-a858-f1e497dcac8c) 
2016-10-27T21:27:26.516 C# Event Hub trigger function processed a message: Timestamp: 10/27/2016 2:27:06 PM, MessageId: 1 
2016-10-27T21:27:26.516 Function completed (Success, Id=d5ed0e23-2b0e-4e0b-a858-f1e497dcac8c) 
2016-10-27T21:33:26.667 Function started (Id=9525a046-86fb-4499-9d4f-b0d0fd0d0829) 
2016-10-27T21:33:26.667 C# Event Hub trigger function processed a message: Timestamp: 10/27/2016 2:33:07 PM, MessageId: 2 
2016-10-27T21:33:26.667 Function completed (Success, Id=9525a046-86fb-4499-9d4f-b0d0fd0d0829) 
2016-10-27T21:39:42.074 Function started (Id=e2d528c9-f1b9-41aa-9c38-669c57c8182a) 
2016-10-27T21:39:42.074 C# Event Hub trigger function processed a message: Timestamp: 10/27/2016 2:39:07 PM, MessageId: 3 
2016-10-27T21:39:42.074 Function completed (Success, Id=e2d528c9-f1b9-41aa-9c38-669c57c8182a) 
2016-10-27T21:45:26.794 Function started (Id=ff5325af-5dab-48fb-95b1-8318fada3c8c) 
2016-10-27T21:45:26.794 C# Event Hub trigger function processed a message: Timestamp: 10/27/2016 2:45:07 PM, MessageId: 4 
2016-10-27T21:45:26.794 Function completed (Success, Id=ff5325af-5dab-48fb-95b1-8318fada3c8c) 
2016-10-27T21:51:26.875 Function started (Id=01d3fbf9-b772-4076-8fbf-783dc16677a7) 
2016-10-27T21:51:26.875 C# Event Hub trigger function processed a message: Timestamp: 10/27/2016 2:51:08 PM, MessageId: 5 
2016-10-27T21:51:26.875 Function completed (Success, Id=01d3fbf9-b772-4076-8fbf-783dc16677a7) 
2016-10-27T21:57:26.989 Function started (Id=443d96e6-af97-460a-9f70-9dbc2eaf2f37) 
2016-10-27T21:57:26.989 C# Event Hub trigger function processed a message: Timestamp: 10/27/2016 2:57:08 PM, MessageId: 6 
2016-10-27T21:57:26.989 Function completed (Success, Id=443d96e6-af97-460a-9f70-9dbc2eaf2f37) 
2016-10-27T22:03:27.088 Function started (Id=9eefe03d-8e78-4119-a453-96655ea01824) 
2016-10-27T22:03:27.088 C# Event Hub trigger function processed a message: Timestamp: 10/27/2016 3:03:08 PM, MessageId: 7 
2016-10-27T22:03:27.088 Function completed (Success, Id=9eefe03d-8e78-4119-a453-96655ea01824) 
2016-10-27T22:10:01.872 Function started (Id=34c9b277-059d-4839-9dce-aeb03afb2871) 
2016-10-27T22:10:01.872 C# Event Hub trigger function processed a message: Timestamp: 10/27/2016 3:09:08 PM, MessageId: 8 
2016-10-27T22:10:01.872 Function completed (Success, Id=34c9b277-059d-4839-9dce-aeb03afb2871) 
2016-10-27T22:15:27.706 Function started (Id=50eda659-c68f-4e61-a942-32160668fd5c) 
2016-10-27T22:15:27.706 C# Event Hub trigger function processed a message: Timestamp: 10/27/2016 3:15:08 PM, MessageId: 9 
2016-10-27T22:15:27.706 Function completed (Success, Id=50eda659-c68f-4e61-a942-32160668fd5c) 
2016-10-27T22:21:52.162 Function started (Id=fa8f8059-013f-42f9-8047-391d4e3fb4a3) 
2016-10-27T22:21:52.162 C# Event Hub trigger function processed a message: Timestamp: 10/27/2016 3:21:08 PM, MessageId: 10 
2016-10-27T22:21:52.162 Function completed (Success, Id=fa8f8059-013f-42f9-8047-391d4e3fb4a3)

正如你可以看到，所有的消息到达没有重复。你能否确认每次调用你的函数（你可以检查你的函数日志），它实际上是否成功完成了？

如果你看到下面的消息，

Function completed (Success, Id=<some Guid>)

为你的函数的每次调用，那么对于执行消息（S）应该已经被设置检查点，你不应该被处理消息（ s）再次在下一次调用。

但是，如果您没有看到消息或看到错误消息，则函数运行失败，这将导致消息不是检查尖端。当功能再次触发时，如果您的功能从未成功处理该消息，它将从最后一个检查点启动，该启动可能是第一个消息。

来源

2016-10-27 23:15:56

更新到v0.7后，它工作。我的动态json对象也存在问题（迄今为止没有任何警告），所以显然你是正确的，假设函数没有正确完成。现在它按照我的预期工作。谢谢你的详细检查，Ramin。 – Ramin

EventHub倾听是基于EventProcessorHost类（https://msdn.microsoft.com/en-us/library/azure/microsoft.servicebus.messaging.eventprocessorhost.aspx）和具有这些默认语义。你是对的，你无法控制起始偏移量。它只是开始收听和检查点。

我们也追踪在维基的更多信息：https://github.com/Azure/azure-webjobs-sdk/wiki/EventHub-support

也欢迎您在https://github.com/Azure/azure-webjobs-sdk/issues/

来源

2016-10-27 04:29:41

在这种情况下，我不明白事件中心触发的功能应用程序的意义。由于myEventHubMessage恰好包含了一个我期望“新”进来的事件（那个触发该函数的事件）。相反，它包含队列中的“第一个”。 – Ramin

功能应用程序的EventHubTrigger按预期工作（请参阅Ling的回答和我的评论）。 – Ramin

@Ramin - 事件中心使用游标。它不读取“最新”，它从阅读器的光标读取。换一种方式;如果您的作者发送了100个事件（并且没有阅读器），然后您启动了一个阅读器，即使它们是在阅读器启动之前发送的，它也会接收这100个事件。 –

偏移Azure中EventHubTrigger功能应用

回答

相关问题