Welcome to the AWS Code Examples Repository. This repo contains code examples used in the AWS documentation, AWS SDK Developer Guides, and more. For more information, see the Readme.md file below.
|
// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
|
||
|
|
// SPDX-License-Identifier: Apache-2.0
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Before running this C++ code example, set up your development environment, including your credentials.
|
||
|
|
*
|
||
|
|
* For more information, see the following documentation topic:
|
||
|
|
*
|
||
|
|
* https://docs.aws.amazon.com/sdk-for-cpp/v1/developer-guide/getting-started.html
|
||
|
|
*
|
||
|
|
* For information on the structure of the code examples and how to build and run the examples, see
|
||
|
|
* https://docs.aws.amazon.com/sdk-for-cpp/v1/developer-guide/getting-started-code-examples.html.
|
||
|
|
*
|
||
|
|
**/
|
||
|
|
|
||
|
|
#include <aws/core/Aws.h>
|
||
|
|
#include <aws/iot/IoTClient.h>
|
||
|
|
#include <aws/iot/model/CreateTopicRuleRequest.h>
|
||
|
|
#include <iostream>
|
||
|
|
#include "iot_samples.h"
|
||
|
|
|
||
|
|
// snippet-start:[cpp.example_code.iot.CreateTopicRule]
|
||
|
|
//! Create an AWS IoT rule with an SNS topic as the target.
|
||
|
|
/*!
|
||
|
|
\param ruleName: The name for the rule.
|
||
|
|
\param snsTopic: The SNS topic ARN for the action.
|
||
|
|
\param sql: The SQL statement used to query the topic.
|
||
|
|
\param roleARN: The IAM role ARN for the action.
|
||
|
|
\param clientConfiguration: AWS client configuration.
|
||
|
|
\return bool: Function succeeded.
|
||
|
|
*/
|
||
|
|
bool
|
||
|
|
AwsDoc::IoT::createTopicRule(const Aws::String &ruleName,
|
||
|
|
const Aws::String &snsTopicARN, const Aws::String &sql,
|
||
|
|
const Aws::String &roleARN,
|
||
|
|
const Aws::Client::ClientConfiguration &clientConfiguration) {
|
||
|
|
Aws::IoT::IoTClient iotClient(clientConfiguration);
|
||
|
|
|
||
|
|
Aws::IoT::Model::CreateTopicRuleRequest request;
|
||
|
|
request.SetRuleName(ruleName);
|
||
|
|
|
||
|
|
Aws::IoT::Model::SnsAction snsAction;
|
||
|
|
snsAction.SetTargetArn(snsTopicARN);
|
||
|
|
snsAction.SetRoleArn(roleARN);
|
||
|
|
|
||
|
|
Aws::IoT::Model::Action action;
|
||
|
|
action.SetSns(snsAction);
|
||
|
|
|
||
|
|
Aws::IoT::Model::TopicRulePayload topicRulePayload;
|
||
|
|
topicRulePayload.SetSql(sql);
|
||
|
|
topicRulePayload.SetActions({action});
|
||
|
|
|
||
|
|
request.SetTopicRulePayload(topicRulePayload);
|
||
|
|
auto outcome = iotClient.CreateTopicRule(request);
|
||
|
|
if (outcome.IsSuccess()) {
|
||
|
|
std::cout << "Successfully created topic rule " << ruleName << "." << std::endl;
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
std::cerr << "Error creating topic rule " << ruleName << ": " <<
|
||
|
|
outcome.GetError().GetMessage() << std::endl;
|
||
|
|
}
|
||
|
|
return outcome.IsSuccess();
|
||
|
|
}
|
||
|
|
// snippet-end:[cpp.example_code.iot.CreateTopicRule]
|
||
|
|
|
||
|
|
/*
|
||
|
|
*
|
||
|
|
* main function
|
||
|
|
*
|
||
|
|
* Usage: 'run_create_topic_rule <rule_name> <topic_arn> <sql> <role_arn>'
|
||
|
|
*
|
||
|
|
*/
|
||
|
|
|
||
|
|
#ifndef EXCLUDE_ACTION_MAIN
|
||
|
|
|
||
|
|
int main(int argc, char **argv) {
|
||
|
|
if (argc != 5) {
|
||
|
|
std::cout
|
||
|
|
<< "Usage: 'run_create_topic_rule <rule_name> <topic_arn> <sql> <role_arn>'"
|
||
|
|
<< std::endl;
|
||
|
|
return 1;
|
||
|
|
}
|
||
|
|
Aws::SDKOptions options;
|
||
|
|
|
||
|
|
Aws::InitAPI(options);
|
||
|
|
{
|
||
|
|
const Aws::String ruleName(argv[1]);
|
||
|
|
const Aws::String snsTopicARN(argv[2]);
|
||
|
|
const Aws::String sql(argv[3]);
|
||
|
|
const Aws::String roleARN(argv[4]);
|
||
|
|
|
||
|
|
Aws::Client::ClientConfiguration clientConfig;
|
||
|
|
// Optional: Set to the AWS Region (overrides config file).
|
||
|
|
// clientConfig.region = "us-east-1";
|
||
|
|
|
||
|
|
AwsDoc::IoT::createTopicRule(ruleName, snsTopicARN, sql, roleARN, clientConfig);
|
||
|
|
}
|
||
|
|
Aws::ShutdownAPI(options);
|
||
|
|
return 0;
|
||
|
|
}
|
||
|
|
|
||
|
|
#endif // EXCLUDE_ACTION_MAIN
|