Bump Newtonsoft.Json from 10.0.3 to 13.0.2 in /samples/DotNet/Microsoft.Azure.EventHubs/AnomalyDetector/Producer

readme.md

@@ -2,7 +2,7 @@
   <img src="event-hubs.png" alt="Microsoft Azure Event Hubs" width="100"/>
 </p>
 
-<h1 align="center">Microsoft Azure Event Hubs
+<h1 align="center">Azure Event Hubs samples
 <p align="center">
   <a href="#star-our-repo">
         <img src="https://img.shields.io/github/stars/azure/azure-event-hubs.svg?style=social&label=Stars"
@@ -12,23 +12,46 @@
             alt="follow on Twitter"></a>
 </p></h1>
 
-We're happy to host our client SDKs and integrations on GitHub as free, open-source projects. We currently support:
+This repository contains samples for Azure Event Hubs. 
 
-* [Event Hubs for Apache Kafka](https://github.com/Azure/azure-event-hubs-for-kafka)
-* [.NET](https://github.com/azure/azure-event-hubs-dotnet)
-* [Java](https://github.com/azure/azure-event-hubs-java)
-* [C](https://github.com/azure/azure-event-hubs-c)
-* [Node.js](https://github.com/azure/azure-event-hubs-node)
-* [Python](https://github.com/azure/azure-event-hubs-python)
-* [Go](https://github.com/azure/azure-event-hubs-go)
-* [Apache Spark connector](https://github.com/Azure/azure-event-hubs-spark)
+## Client SDK samples
 
-If you have any feedback, questions, or comments, go to the respective repo and file an issue. **Your involvement is welcome and encouraged!**
+> **Note:** This repository holds samples for the legacy libraries for Azure Event Hubs for .NET and Java developers. We highly recommend you to upgrade to the newer packages.
+
+.NET legacy packages
+
+- Microsoft.Azure.EventHubs (**legacy**)
+- Microsoft.Azure.EventHubs.Processor (**legacy**)
+- WindowsAzure.ServiceBus (**legacy**)
+
+Java legacy packages
+
+- com.microsoft.azure:azure-eventhubs (**legacy**)
+- com.microsoft.azure:azure-eventhubs-eph (**legacy**)
+
+Samples for **latest** .NET packages for Azure Event Hubs
 
-## What is Event Hubs?
+- [Azure.Messaging.EventHubs](https://docs.microsoft.com/samples/azure/azure-sdk-for-net/azuremessagingeventhubs-samples/)
+- [Azure.Messaging.EventHubs.Processor](https://docs.microsoft.com/samples/azure/azure-sdk-for-net/azuremessagingeventhubsprocessor-samples/)
+
+Samples for **latest** Java packages for Azure Event Hubs
+
+- [com.azure:azure-messaging-eventhubs](https://github.com/Azure/azure-sdk-for-java/tree/master/sdk/eventhubs/azure-messaging-eventhubs/src/samples)
+- [com.azure:azure-messaging-eventhubs-checkpointstore-blob](https://github.com/Azure/azure-sdk-for-java/tree/master/sdk/eventhubs/azure-messaging-eventhubs-checkpointstore-blob/src/samples)
+
+You can find samples for other languages and frameworks in the following repositories: 
+- [JavaScript](https://github.com/Azure/azure-sdk-for-js/tree/master/sdk/eventhub/event-hubs/samples)
+- [Python](https://github.com/Azure/azure-sdk-for-python/tree/master/sdk/eventhub/azure-eventhub/samples)
+- [C](https://github.com/azure/azure-event-hubs-c)
+- [Go](https://github.com/azure/azure-event-hubs-go)
+- [Apache Spark connector](https://github.com/Azure/azure-event-hubs-spark)
+- [Event Hubs for Apache Kafka](https://github.com/Azure/azure-event-hubs-for-kafka)
+
+If you have any feedback, questions, or comments, go to the respective repo and file an issue. **Your involvement is welcome and encouraged!**
 
-Azure Event Hubs is a hyper-scale data ingestion service, fully-managed by Microsoft, that enables you to collect, store and process trillions of events from websites, apps, IoT devices, and any stream of data. To learn more, please visit our [marketing page](https://azure.microsoft.com/services/event-hubs/).
+## Management SDK samples
+This repository also contains [management samples](https://github.com/Azure/azure-event-hubs/tree/master/samples/Management) that use the .NET management SDK, PowerShell, and CLI. 
 
-## Azure Event Hubs for Apache Kafka
 
-Event Hubs now provides a Kafka endpoint that can be used by your existing Kafka-based applications as an alternative to running your own Kafka cluster. To learn more, check out the new [Azure Event Hubs for Apache Kafka](https://github.com/Azure/azure-event-hubs-for-kafka) repo!
+## See also
+To learn about Event Hubs, see our [Event Hubs documentation](https://docs.microsoft.com/en-us/azure/event-hubs/).

samples/DotNet/AnomalyDetector/Producer/Producer.csproj → samples/DotNet/Azure.Messaging.EventHubs/AnomalyDetector/Producer/Producer.csproj

@@ -6,8 +6,8 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Microsoft.Azure.EventHubs" Version="1.1.0" />
-    <PackageReference Include="Newtonsoft.Json" Version="10.0.3" />
+    <PackageReference Include="Azure.Messaging.EventHubs" Version="5.0.1" />
+    <PackageReference Include="Newtonsoft.Json" Version="12.0.3" />
   </ItemGroup>
 
 </Project>

samples/DotNet/Azure.Messaging.EventHubs/AnomalyDetector/Producer/Program.cs

@@ -0,0 +1,103 @@
+// Copyright (c) Microsoft. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+namespace Producer
+{
+    using System;
+    using System.Text;
+    using System.Threading.Tasks;
+    using Azure.Messaging.EventHubs;
+    using Azure.Messaging.EventHubs.Producer;
+    using System.Collections.Generic;
+    using System.IO;
+
+    public class Program
+    {
+        private const string EventHubNamespaceConnectionString = "<EVENT HUBS NAMESPACE CONNECTION STRING>";
+        private const string EventHubName = "<EVENT HUB NAME>";
+        private const string TransactionsDumpFile = "mocktransactions.csv";
+
+        private static EventHubProducerClient producerClient;
+
+        static async Task Main()
+        {
+            // create an Event Hubs Producer client using the namespace connection string and the event hub name
+            producerClient = new EventHubProducerClient(EventHubNamespaceConnectionString, EventHubName);
+
+            // send messages to the event hub
+            await SendMessagesToEventHubAsync(1000);
+
+            await producerClient.CloseAsync();
+
+            Console.WriteLine("Press [enter] to exit.");
+            Console.ReadLine();
+        }
+
+        // Creates an Event Hub client and sends messages to the event hub.
+        private static async Task SendMessagesToEventHubAsync(int numMessagesToSend)
+        {
+            var eg = new EventGenerator();
+
+            IEnumerable<Transaction> transactions = eg.GenerateEvents(numMessagesToSend);
+
+            if (File.Exists(TransactionsDumpFile))
+            {
+                // exceptions not handled for brevity
+                File.Delete(TransactionsDumpFile);
+            }
+
+            await File.AppendAllTextAsync(
+                TransactionsDumpFile, 
+                $"CreditCardId,Timestamp,Location,Amount,Type{Environment.NewLine}");
+
+            int numSuccessfulMessages = 0;
+            try
+            {
+                // create a batch using the producer client
+                using (EventDataBatch eventBatch = await producerClient.CreateBatchAsync())
+                {
+                    foreach (var t in transactions)
+                    {
+                        // we don't send the transaction type as part of the message.
+                        // that is up to the downstream analytics to figure out!
+                        // we just pretty print them here so they can easily be compared with the downstream
+                        // analytics results.
+                        var message = t.Data.ToJson();
+
+                        if (t.Type == TransactionType.Suspect)
+                        {
+                            var fc = Console.ForegroundColor;
+                            Console.ForegroundColor = ConsoleColor.Yellow;
+
+                            Console.WriteLine($"Suspect transaction: {message}");
+
+                            Console.ForegroundColor = fc; // reset to original
+                        }
+                        else
+                        {
+                            Console.WriteLine($"Regular transaction: {message}");
+                        }
+
+                        var line = $"{t.Data.CreditCardId},{t.Data.Timestamp.ToString("o")},{t.Data.Location},{t.Data.Amount},{t.Type}{Environment.NewLine}";
+
+                        File.AppendAllText(TransactionsDumpFile, line);
+
+                        // add the message to the batch
+                        eventBatch.TryAdd(new EventData(Encoding.UTF8.GetBytes(message)));
+                        numSuccessfulMessages++;
+                    }
+                    // send the batch of messages to the event hub using the producer object
+                    await producerClient.SendAsync(eventBatch);
+                    await Task.Delay(10);
+                }
+            }
+            catch (Exception ex)
+            {
+                Console.WriteLine($"{Environment.NewLine}Exception: {ex.Message}");
+            }
+            Console.WriteLine();
+            Console.WriteLine($"{numSuccessfulMessages} messages sent successfully.");
+        }
+    }
+}
+

samples/DotNet/Azure.Messaging.EventHubs/AnomalyDetector/Readme.md

@@ -0,0 +1,5 @@
+
+# Visualize data anomalies in real-time events sent to Azure Event Hubs
+In this sample, you run an application that creates and sends credit card transactions to an event hub. Then you read the stream of data in real-time with Azure Stream Analytics, which separates the valid transactions from the invalid transactions, and then use Power BI to visually identify the transactions that are tagged as invalid.
+
+For detailed information and steps for using this sample, see [this article](https://docs.microsoft.com/azure/event-hubs/event-hubs-tutorial-visualize-anomalies). 

samples/DotNet/Azure.Messaging.EventHubs/ManagedIdentityWebApp/Global.asax

@@ -0,0 +1 @@
+<%@ Application Codebehind="Global.asax.cs" Inherits="ManagedIdentityWebApp.Global" Language="C#" %>

samples/DotNet/MSI/EventHubsMSIDemoWebApp/EventHubsMSIDemoWebApp/Global.asax.cs → samples/DotNet/Azure.Messaging.EventHubs/ManagedIdentityWebApp/Global.asax.cs

@@ -5,7 +5,7 @@
 using System.Web.Security;
 using System.Web.SessionState;
 
-namespace EventHubsMSIDemoWebApp
+namespace ManagedIdentityWebApp
 {
     public class Global : System.Web.HttpApplication
     {