# Azue Event Hubs 集成 針對 Microsoft Azure Eventhubs 的 Storm spout 和 bolt 實現 ### build ``` mvn clean package ``` ### 運行 topology 示例 要運行 topology 示例, 您需要去修改 config.properties 文件與 eventhubs 配置. 以下是一個例子: ``` eventhubspout.username = [username: policy name in EventHubs Portal] eventhubspout.password = [password: shared access key in EventHubs Portal] eventhubspout.namespace = [namespace] eventhubspout.entitypath = [entitypath] eventhubspout.partitions.count = [partitioncount] # if not provided, will use storm's zookeeper settings # zookeeper.connectionstring=zookeeper0:2181,zookeeper1:2181,zookeeper2:2181 eventhubspout.checkpoint.interval = 10 eventhub.receiver.credits = 1024 ``` 然后您可以使用 storm.cmd 來提交 topology 示例: ``` storm jar {jarfile} com.microsoft.eventhubs.samples.EventCount {topologyname} {spoutconffile} where the {jarfile} should be: eventhubs-storm-spout-{version}-jar-with-dependencies.jar ``` ### 運行 EventHubSendClient 我們包括一個簡單的 EventHubs send client 用于測試. 您可以像下面這樣來運行 client: ``` java -cp .\target\eventhubs-storm-spout-{version}-jar-with-dependencies.jar com.microsoft.eventhubs.client.EventHubSendClient [username] [password] [entityPath] [partitionId] [messageSize] [messageCount] ``` 如果想要發送消息到所有的 partition（分區）, 使用 "-1" 作為 partitionId. ### Windows Azure Eventhubs ``` http://azure.microsoft.com/en-us/services/event-hubs/ ```