查看事件通知(C SDK)

方法定义

void get_notification_configuration(const obs_options *options,
        obs_smn_handler *handler,  void *callback_data);

参数解释

代码示例

#include "eSDKOBS.h"
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

// 响应回调函数，可以在这个回调中把properties的内容记录到callback_data(用户自定义回调数据)中
obs_status response_properties_callback(const obs_response_properties *properties, void *callback_data);
// 结束回调函数，可以在这个回调中把obs_status和obs_error_details的内容记录到callback_data(用户自定义回调数据)中
void response_complete_callback(obs_status status, const obs_error_details *error, void *callback_data);
// 查看事件通知配置的回调函数，解析返回的notification_conf结构体
obs_status get_notification_info_callback(obs_smn_notification_configuration *notification_conf, void *callback_data);

int main()
{
    // 以下示例展示如何查看桶事件通知配置：
    // 在程序入口调用obs_initialize方法来初始化网络、内存等全局资源。
    obs_status ret_status = obs_initialize(OBS_INIT_ALL);
    if (OBS_STATUS_OK != ret_status) {
        printf("obs_initialize failed(%s).\n", obs_get_status_name(ret_status));
        return -1;
    }

    obs_options options;
    // 创建并初始化options，该参数包括访问域名(host_name)、访问密钥(access_key_id和access_key_secret)、桶名(bucket_name)、桶存储类别(storage_class)等配置信息
    init_obs_options(&options);
    // host_name填写桶所在的endpoint, 此处以华北-北京四为例，其他地区请按实际情况填写。
    options.bucket_options.host_name = "obs.cn-north-4.myhuaweicloud.com";
   
    
   
   
    
    
    // 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全；本示例以ak和sk保存在环境变量中为例，运行本示例前请先在本地环境中设置环境变量ACCESS_KEY_ID和SECRET_ACCESS_KEY。
    // 您可以登录访问管理控制台获取访问密钥AK/SK
    options.bucket_options.access_key = getenv("ACCESS_KEY_ID");
    options.bucket_options.secret_access_key = getenv("SECRET_ACCESS_KEY");
    // 填写Bucket名称，例如example-bucket-name。
    char *bucketName = "example-bucket-name";
    options.bucket_options.bucket_name = bucketName;

    // 设置回调函数（含响应回调与查看通知配置的数据回调）
    obs_smn_handler notification_handler_info = {
        {&response_properties_callback, &response_complete_callback},
        &get_notification_info_callback};

    ret_status = OBS_STATUS_BUTT;
    // 查看桶事件通知配置
    get_notification_configuration(&options, &notification_handler_info, &ret_status);
    if (OBS_STATUS_OK == ret_status) {
        printf("get_notification_config success.\n");
    } else {
        printf("get_notification_config failed(%s).\n", obs_get_status_name(ret_status));
    }

    // 释放分配的全局资源
    obs_deinitialize();
    return 0;
}

// 查看事件通知配置的回调函数，解析返回的notification_conf结构体
obs_status get_notification_info_callback(obs_smn_notification_configuration *notification_conf, void *callback_data)
{
    int i = 0;
    int j = 0;
    (void)callback_data;
    if (notification_conf == NULL) {
        printf("notification_conf is null.\n");
        return OBS_STATUS_OK;
    }
    printf("topic_conf_num=%d\n", notification_conf->topic_conf_num);

    for (i = 0; i < notification_conf->topic_conf_num; i++) {
        printf("******************** num(%d) *************************\n", i);
        printf("id: %s\n", notification_conf->topic_conf[i].id ? notification_conf->topic_conf[i].id : "(null)");
        printf("topic: %s\n", notification_conf->topic_conf[i].topic ? notification_conf->topic_conf[i].topic : "(null)");
        printf("event_num: %d\n", notification_conf->topic_conf[i].event_num);
        for (j = 0; j < notification_conf->topic_conf[i].event_num; j++) {
            printf("    event: %d\n", notification_conf->topic_conf[i].event[j]);
        }
        printf("filter_rule_num: %d\n", notification_conf->topic_conf[i].filter_rule_num);
        for (j = 0; j < notification_conf->topic_conf[i].filter_rule_num; j++) {
            printf("    name: %d, value: %s\n",
                   notification_conf->topic_conf[i].filter_rule[j].name,
                   notification_conf->topic_conf[i].filter_rule[j].value ? notification_conf->topic_conf[i].filter_rule[j].value : "(null)");
        }
    }
    return OBS_STATUS_OK;
}

// 响应回调函数，可以在这个回调中把properties的内容记录到callback_data(用户自定义回调数据)中
obs_status response_properties_callback(const obs_response_properties *properties, void *callback_data)
{
    (void)callback_data;
    if (properties == NULL) {
        return OBS_STATUS_OK;
    }
    if (properties->request_id) {
        printf("request_id: %s\n", properties->request_id);
    }
    if (properties->request_id2) {
        printf("request_id2: %s\n", properties->request_id2);
    }
    return OBS_STATUS_OK;
}

// 结束回调函数，可以在这个回调中把obs_status和obs_error_details的内容记录到callback_data(用户自定义回调数据)中
void response_complete_callback(obs_status status, const obs_error_details *error, void *callback_data)
{
    obs_status *ret_status = (obs_status *)callback_data;
    if (ret_status) {
        *ret_status = status;
    }
    if (error && error->message) {
        printf("Error Message: %s\n", error->message);
    }
    if (error && error->resource) {
        printf("Error Resource: %s\n", error->resource);
    }
    if (error && error->extra_details_count) {
        int i;
        for (i = 0; i < error->extra_details_count; i++) {
            printf("Error Extra Detail(%d): %s:%s\n", i,
                   error->extra_details[i].name, error->extra_details[i].value);
        }
    }
}