Senden von Daten von Python zu Azure Event Hub

import pandas as pd
from azure.eventhub import EventData, EventHubProducerClient

data= pd.read_csv('testdata.csv').drop("Unnamed: 0",axis=1)
message = data.iloc[0].to_json()


EVENT_HUB_CONNECTION_STR = "Endpoint=sb://eventhubdrohne.servicebus.windows.net/;SharedAccessKeyName=python;SharedAccessKey=6y/5b0JJKM/GzzgCsUvIzWEip4pyisIhs+AEhJCXdnQ=;EntityPath=drohne"
EVENT_HUB_NAME = "drohne"

producer = EventHubProducerClient.from_connection_string(
        conn_str=EVENT_HUB_CONNECTION_STR, eventhub_name=EVENT_HUB_NAME
    )

event_data_batch = producer.create_batch()
event_data_batch.add(EventData(message))

with producer:
    producer.send_batch(event_data_batch)

Last updated