C# as sender and python as receiver in Azure event hub

Question

I have an IoT device that is connected to Azure event hub. I'm trying to make this device communicate with azure databricks and azure event hub is placed in between as a middleware. The problem is that after we are able to send messages via ".NET framework", it is never shown in messages received in "python" command line (we should do that as we work separately for each part)

I followed the guidelines .NET framework as sender and python as receiver, and this doesn't work.

I am seeing that there are spikes in the request and message graphs under event hub stream instances, but it just never shows in the receiver

==================================UPDATE==================================

Just deleted the eventhub and recreated and it seems work.

However, messages are received in the form of long strings something like this below:

Received: 662a2a44-4414-4cb5-a9e9-a08d12a417e0
Received: b68ef8f8-305f-4726-84e4-f35b76de30c5
Received: e94dfb73-972c-47b4-baef-1ab41b06be28
Received: 8eda384d-f79d-4cdf-9db3-fe5c2156553b
Received: d154283f-a8c2-4a4c-a7d5-e8d8129b568d
Received: 3e3e190e-f883-416c-a5be-b8cd8547d152
Received: e218c63b-85b3-4f4f-8f04-cb5ffc6d8921
Received: 0adec5ad-e351-4151-ba56-01093e0f383d
Received 8 messages in 0.05406975746154785 seconds

This happens when I read the messages in format below:

print("Received: {}".format(event_data.body_as_str(encoding='UTF-8')))

Answer 1

I just give it a try, and I can repro your issue. And here are something you need to check.

1.In you sender(in c#), you should make sure your message to send is correct. Like below:

    static void SendingRandomMessages()
    {
        var eventHubClient = EventHubClient.CreateFromConnectionString(connectionString, eventHubName);
        int i = 0;
        while (true)
        {
            try
            {
                // make sure the message is correct.
                var message = i+":"+Guid.NewGuid().ToString()+":"+DateTime.Now;

                Console.WriteLine("{0} > Sending message: {1}", DateTime.Now, message);
                var myeventdata = new EventData(Encoding.UTF8.GetBytes(message));
                eventHubClient.Send(myeventdata);
                i++;
                //eventHubClient.Send(new EventData(Encoding.UTF8.GetBytes(message)));
            }
            catch (Exception exception)
            {
                Console.ForegroundColor = ConsoleColor.Red;
                Console.WriteLine("{0} > Exception: {1}", DateTime.Now, exception.Message);
                Console.ResetColor();
            }

            Thread.Sleep(2000);
        }
    }

2.There seems some delay for the receiver(in python), so I execute the python receiver about 3 times, and I can see the expected output. The screenshot as below:

Update 1022: as we discussed in the comment, there is a solution for fixing just receiving even / odd number event data.

In you sender(in c#), use the code below, which sends event data to partition 0:

        static void SendingRandomMessages()
        {
            var eventHubClient = EventHubClient.CreateFromConnectionString(connectionString, eventHubName);
            var myclient = eventHubClient.CreatePartitionedSender("0");
            int i = 30;

            while (true)
            {
                var message = i + ":" + Guid.NewGuid().ToString() + ":" + DateTime.Now;

                Console.WriteLine("{0} > Sending message: {1}", DateTime.Now, message);
                var myeventdata = new EventData(Encoding.UTF8.GetBytes(message));
                myclient.Send(myeventdata);
                i++;
                Thread.Sleep(2000);
            }
          }

then in your receiver(in python), specify the partition to 0(use this PARTITION = "0"), then you can get all the event data.