[EventHub] add EventData.from_bytes (Azure#39952)

* [EventHub] add EventData.from_bytes

* copilot comments

* fix test

Author: swathipil

sdk/eventhub/azure-eventhub/CHANGELOG.md

@@ -1,6 +1,10 @@
 # Release History
 
-## 5.14.1 (Unreleased)
+## 5.15.0 (Unreleased)
+
+### Features Added
+
+- Added a class method `from bytes` to create `EventData` from a message payload of bytes. ([#39711](https://github.com/Azure/azure-sdk-for-python/issues/39711))
 
 ### Bugs Fixed
 
@@ -10,7 +14,7 @@
 
 ### Features Added
 
-- Add support for Decimal128 in pyAMQP ([#39511]https://github.com/Azure/azure-sdk-for-python/pull/39511)
+- Add support for Decimal128 in pyAMQP ([#39511](https://github.com/Azure/azure-sdk-for-python/pull/39511))
 
 ### Bugs Fixed
 

sdk/eventhub/azure-eventhub/azure/eventhub/_common.py

@@ -55,6 +55,7 @@
 )
 from ._pyamqp._message_backcompat import LegacyMessage, LegacyBatchMessage
 from ._pyamqp.message import Message as pyamqp_Message
+from ._pyamqp._decode import decode_payload
 from ._transport._pyamqp_transport import PyamqpTransport
 
 if TYPE_CHECKING:
@@ -223,6 +224,15 @@ def from_message_content(  # pylint: disable=unused-argument
         event_data.content_type = content_type
         return event_data
 
+    @classmethod
+    def from_bytes(cls, message: bytes) -> "EventData":
+
+        amqp_message = decode_payload(memoryview(message))
+        event_data = cls(body="")
+        event_data._message = amqp_message
+        event_data._raw_amqp_message = AmqpAnnotatedMessage(message=amqp_message)
+        return event_data
+
     @classmethod
     def _from_message(
         cls,

sdk/eventhub/azure-eventhub/azure/eventhub/_version.py

@@ -4,4 +4,4 @@
 # ------------------------------------
 
 
-VERSION = "5.14.1"
+VERSION = "5.15.0"

sdk/eventhub/azure-eventhub/tests/unittest/test_event_data.py

@@ -7,6 +7,7 @@
 
 import platform
 import pytest
+import datetime
 from packaging import version
 
 try:
@@ -369,3 +370,16 @@ def test_legacy_message(uamqp_transport):
     assert event_data_batch.message.header.priority is None
     assert event_data_batch.message.on_send_complete is None
     assert event_data_batch.message.properties is None
+
+def test_from_bytes(uamqp_transport):
+    if uamqp_transport:
+        pytest.skip("This test is only for pyamqp transport")
+    data = b'\x00Sr\xc1\x87\x08\xa3\x1bx-opt-sequence-number-epochT\xff\xa3\x15x-opt-sequence-numberU\x00\xa3\x0cx-opt-offsetU\x00\xa3\x13x-opt-enqueued-time\x00\xa3\x1dcom.microsoft:datetime-offset\x83\x00\x00\x01\x95\xf3XB\x86\x00St\xc1I\x02\xa1\rDiagnostic-Id\xa1700-1aa201483d464ac3c3d2ab796fbccb36-72e947bb22f404fc-00\x00Su\xa0\x08message1'
+
+    event_data = EventData.from_bytes(data)
+    assert event_data.body_as_str() == 'message1'
+    assert event_data.sequence_number == 0
+    assert event_data.offset is None
+    assert event_data.properties == {b'Diagnostic-Id': b'00-1aa201483d464ac3c3d2ab796fbccb36-72e947bb22f404fc-00'}
+    assert event_data.partition_key is None
+    assert isinstance(event_data.enqueued_time, datetime.datetime)