Quickstart: Gebeurtenissen verzenden naar Azure Event Hubs met behulp van C

  • Artikel

Inleiding

Azure Event Hubs is een big data-platform voor het streamen van gegevens en een gebeurtenisopneemservice die miljoenen gebeurtenissen per seconde kan opnemen en verwerken. Event Hubs kan gebeurtenissen, gegevens of telemetrie die wordt geproduceerd door gedistribueerde software en apparaten verwerken en opslaan. Gegevens die naar een Event Hub worden verzonden, kunnen worden omgezet en opgeslagen via een provider voor realtime analytische gegevens of batchverwerking/opslagadapters. Zie Overzicht van Event Hubs en Functies van Event Hubs voor een gedetailleerd overzicht van Event Hubs.

In deze zelfstudie wordt beschreven hoe u met een consoletoepassing in C gebeurtenissen naar een Event Hub verzendt.

Vereisten

U hebt het volgende nodig om deze zelfstudie af te ronden:

  • Een C-ontwikkelomgeving. In deze zelfstudie wordt uitgegaan van de gcc-stack op een Azure Linux-VM met Ubuntu 14.04.
  • Microsoft Visual Studio.
  • Een Event Hubs-naamruimte en een Event Hub maken. Gebruik de Azure-portal om een naamruimte van het type Event Hubs te maken en de beheerreferenties te verkrijgen die de toepassing nodig heeft om met de Event Hub te communiceren. Volg de procedure in dit artikel om een naamruimte en een Event Hub te maken. Haal de waarde van de toegangssleutel voor de Event Hub op door de instructies in het artikel te volgen: Get verbindingsreeks. U gebruikt de toegangssleutel in de code die u verderop in deze zelfstudie schrijft. De standaardsleutelnaam is: RootManageSharedAccessKey.

Code schrijven om berichten te verzenden naar Event Hubs

In deze sectie wordt beschreven hoe u een C-app schrijft waarmee gebeurtenissen worden verzonden naar uw Event Hub. De code maakt gebruik van de Proton AMQP-bibliotheek van het Apache Qpid-project. Dit is vergelijkbaar met het gebruik van Service Bus-wachtrijen en onderwerpen met AMQP van C, zoals wordt weergegeven in dit voorbeeld. Zie de documentatie bij Qpid Proton voor meer informatie.

  1. Volg op de pagina QPid AMQP Messenger de instructies voor het installeren van QPid Proton, afhankelijk van uw omgeving.

  2. Als u de Proton-bibliotheek wilt compileren, installeert u de volgende pakketten:

    sudo apt-get install build-essential cmake uuid-dev openssl libssl-dev

  3. Download de QPid Proton-bibliotheek en pak deze uit, bijvoorbeeld:

    wget https://archive.apache.org/dist/qpid/proton/0.7/qpid-proton-0.7.tar.gz
tar xvfz qpid-proton-0.7.tar.gz

  4. Een buildmap maken, compileren en installeren:

    cd qpid-proton-0.7
mkdir build
cd build
cmake -DCMAKE_INSTALL_PREFIX=/usr ..
sudo make install

  5. Maak in uw werkmap een nieuw bestand met de naam sender.c en met de volgende code. Vergeet niet om de waarden voor de SAS-sleutel/-naam, Event Hub-naam en naamruimte te vervangen. U moet ook een URL-gecodeerde versie van de sleutel vervangen door de SendRule die u eerder hebt gemaakt. U kunt de URL hier coderen.

    #include "proton/message.h"
#include "proton/messenger.h"

#include <getopt.h>
#include <proton/util.h>
#include <sys/time.h>
#include <stddef.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include <signal.h>

volatile sig_atomic_t stop = 0;

#define check(messenger)                                                     \
  {                                                                          \
    if(pn_messenger_errno(messenger))                                        \
    {                                                                        \
      printf("check\n");                                                     \
      die(__FILE__, __LINE__, pn_error_text(pn_messenger_error(messenger))); \
    }                                                                        \
  }

void interrupt_handler(int signum){
  if(signum == SIGINT){
    stop = 1;
  }
}

pn_timestamp_t time_now(void)
{
  struct timeval now;
  if (gettimeofday(&now, NULL)) pn_fatal("gettimeofday failed\n");
  return ((pn_timestamp_t)now.tv_sec) * 1000 + (now.tv_usec / 1000);
}

void die(const char *file, int line, const char *message)
{
  printf("Dead\n");
  fprintf(stderr, "%s:%i: %s\n", file, line, message);
  exit(1);
}

int sendMessage(pn_messenger_t * messenger) {
    char * address = (char *) "amqps://{SAS Key Name}:{SAS key}@{namespace name}.servicebus.windows.net/{event hub name}";
    char * msgtext = (char *) "Hello from C!";

    pn_message_t * message;
    pn_data_t * body;
    message = pn_message();

    pn_message_set_address(message, address);
    pn_message_set_content_type(message, (char*) "application/octect-stream");
    pn_message_set_inferred(message, true);

    body = pn_message_body(message);
    pn_data_put_binary(body, pn_bytes(strlen(msgtext), msgtext));

    pn_messenger_put(messenger, message);
    check(messenger);
    pn_messenger_send(messenger, 1);
    check(messenger);

    pn_message_free(message);
}

int main(int argc, char** argv) {
    printf("Press Ctrl-C to stop the sender process\n");
    signal(SIGINT, interrupt_handler);

    pn_messenger_t *messenger = pn_messenger(NULL);
    pn_messenger_set_outgoing_window(messenger, 1);
    pn_messenger_start(messenger);

    while(!stop) {
        sendMessage(messenger);
        printf("Sent message\n");
        sleep(1);
    }

    // release messenger resources
    pn_messenger_stop(messenger);
    pn_messenger_free(messenger);

    return 0;
}

  6. Compileer het bestand, uitgaande van gcc:

    gcc sender.c -o sender -lqpid-proton

    Notitie

    Deze code maakt gebruik van een uitgaand venster van 1 om het verzenden van de berichten zo snel mogelijk af te dwingen. U wordt aangeraden de toepassing zo in te stellen dat berichten in batches worden verzonden om de doorvoer te verbeteren. Zie de pagina Qpid AMQP Messenger voor informatie over het gebruik van de Qpid Proton-bibliotheek in deze en andere omgevingen en vanaf platforms waarvoor bindingen worden geleverd (momenteel Perl, PHP, Python en Ruby).

Voer de toepassing uit om berichten naar de Event Hub te verzenden.

Gefeliciteerd U hebt nu berichten verzonden naar een Event Hub.

Volgende stappen

Lees de volgende artikelen: