使用可选字段从 RPI3 向 kaa 服务器发送日志模式

Question

我正在尝试从 raspberry pi C 应用程序发送日志模式到后端 kaa 服务器。这是架构

{
"type" : "record",
"name" : "RemoteSensorLog",
"namespace" : "org.kaa.iot.log.sensor",
"fields" : [ {
"name" : "deviceId",
"type" : {
  "type" : "string",
  "avro.java.string" : "String"
}
}, {
  "name" : "temperature",
  "type" : [ "double", "null" ]
}, {
  "name" : "humidity",
  "type" : [ "long", "null" ]
}, {
  "name" : "batteryLevel",
  "type" : [ "int", "null" ]
} ],
"version" : 1,
"dependencies" : [ ],
"displayName" : "RemoteSensorLog",
"description" : "This is the log sent by remote sensors"
}

log schema中的一些项目是可选的，这里是初始化函数

void kaaLogInitializing(void *context)
{
    void *log_storage_context = NULL;
    void *log_upload_strategy_context = NULL;

    printf("Initializing the Kaa log\n");

    kaa_client_t * kaa_client_context = context;

    if (context == NULL) {
            return;
    }

    /* Log delivery listener callbacks. Each callback called whenever something happen with a log bucket. */
    kaa_log_delivery_listener_t log_listener = {
            .on_success = success_log_delivery_callback, /* Called if log delivered successfully */
            .on_failed  = failed_log_delivery_callback, /* Called if delivery failed */
            .on_timeout = timeout_log_delivery_callback, /* Called if timeout occurs */
            .ctx        = kaa_client_context, /* Optional context */
    };

    /* The internal memory log storage distributed with Kaa SDK */
    kaa_error_t error_code = ext_unlimited_log_storage_create(&log_storage_context,
                                                              kaa_client_get_context(
                                                                      kaa_client_context
                                                                      )->logger
                                                              );

    if (error_code) {
            printf("Failed to create Kaa log storage %d\r\n", error_code);
            return;
    }

    error_code = ext_log_upload_strategy_create(kaa_client_get_context(
                                                        kaa_client_context),
                                                &log_upload_strategy_context, KAA_LOG_UPLOAD_VOLUME_STRATEGY);

    if (error_code) {
            printf("Failed to create log upload strategy, error code %d\r\n", error_code);
            return;
    }

    error_code = ext_log_upload_strategy_set_threshold_count(log_upload_strategy_context,
                                                             LOG_UPLOAD_THRESHOLD);

    if (error_code) {
            printf("Failed to set threshold log record count, error code %d\r\n", error_code);
            return;
    }

    error_code = kaa_logging_set_strategy(kaa_client_get_context(kaa_client_context)->log_collector,
                                          log_upload_strategy_context);

    if (error_code) {
            printf("Failed to set log upload strategy, error code %d\r\n", error_code);
            return;
    }

    /* Specify log bucket size constraints */
    kaa_log_bucket_constraints_t bucket_sizes = {
            .max_bucket_size       = MAX_LOG_BUCKET_SIZE, /* Bucket size in bytes */
            .max_bucket_log_count  = MAX_LOG_COUNT, /* Maximum log count in one bucket */
    };

    /* Initialize the log storage and strategy (by default it is not set) */
    error_code = kaa_logging_init(kaa_client_get_context(
                                          kaa_client_context)->log_collector
                                  , log_storage_context
                                  , log_upload_strategy_context
                                  , &bucket_sizes);

    if (error_code) {
            printf("Failed to initialize Kaa log %d\r\n", error_code);
            return;
    }

    /* Add listeners to a log collector */
    kaa_logging_set_listeners(kaa_client_get_context(
                                      kaa_client_context)->log_collector,
                              &log_listener);
}

这是我用来发送日志的函数

void sendLog(void *context)
{
    kaa_client_t * kaa_client_context = context;
    float temperature = 25.5;

    if (context == NULL) {
            return;
    }

    logDelivered = LOG_DELIVERY_DELIVERING;

            printf("Start attempt to send Log\n");

    kaa_logging_remote_sensor_log_t *log_record = kaa_logging_remote_sensor_log_create();

    log_record->device_id = kaa_string_copy_create("Dev1");
    log_record->temperature = kaa_logging_union_double_or_null_branch_0_create();
    log_record->temperature->data = &temperature; /* create subobject */

    log_record->humidity = kaa_logging_union_long_or_null_branch_1_create();
    log_record->battery_level = kaa_logging_union_int_or_null_branch_1_create();

            printf("Log record created\n");
    /* Log information. Populated when log is added via kaa_logging_add_record() */
    kaa_log_record_info_t log_info;

    kaa_error_t error = kaa_logging_add_record(
            kaa_client_get_context(kaa_client_context)->log_collector,
            log_record, &log_info);

    if (error) {
            printf("Failed to add log record, error code\r\n");
            kaa_client_stop(kaa_client_context);
            return;
    }

    //log_record->destroy(log_record);
}

我有 2 个问题

问题 1 ####：如果我取消注释 sendLog 函数中的最后一行 log_record->destroy(log_record); 我会收到此错误 double free or corruption (out): 0x7efe05
问题 2 #### ：在评论提到的行和运行应用程序之后，我从来没有收到任何错误或服务器获取日志似乎什么都没有发生我收到的日志发送成功或失败或超时.

Answer 1

您需要手动分配内存来存储温度值。它将在log_record->destroy(log_record).

中释放

因此，您需要执行以下操作：

double *p_temperature = KAA_MALLOC(sizeof(double));
if (!p_temperature) {
    // error handling
}

*p_temperature = 25.5;
log_record->temperature->data = p_temperature;

使用可选字段从 RPI3 向 kaa 服务器发送日志模式

Sending log schema to kaa server from RPI3 with optional fields

c

raspberry-pi

kaa