2022-12-08 15:49:42 -05:00
// 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.
*
* Purpose
*
* Demonstrates using the AWS SDK for C++ to create and invoke an AWS Lambda function.
*
* 1. Create an AWS Identity and Access Management (IAM) role for a Lambda function.
* 2. Create a Lambda function.
* 3. Invoke the Lambda function.
* 4. Update the Lambda function code.
* 5. Update the Lambda function configuration.
* 6. Invoke the updated Lambda function.
* 7. List the Lambda functions.
* 8. Get a Lambda function.
* 9. Delete the Lambda function.
* 10. Delete the IAM role.
*
*/
2023-02-09 17:01:55 -05:00
# include <thread>
2022-12-08 15:49:42 -05:00
# include <aws/core/Aws.h>
# include <aws/iam/IAMClient.h>
# include <aws/iam/model/CreateRoleRequest.h>
# include <aws/iam/model/AttachRolePolicyRequest.h>
# include <aws/iam/model/DeleteRoleRequest.h>
# include <aws/iam/model/DetachRolePolicyRequest.h>
# include <aws/iam/model/GetRoleRequest.h>
# include <aws/iam/model/ListAttachedRolePoliciesRequest.h>
# include <aws/lambda/LambdaClient.h>
# include <aws/lambda/model/CreateFunctionRequest.h>
# include <aws/lambda/model/DeleteFunctionRequest.h>
# include <aws/lambda/model/GetFunctionRequest.h>
# include <aws/lambda/model/GetFunctionConfigurationRequest.h>
# include <aws/lambda/model/InvokeRequest.h>
# include <aws/lambda/model/ListFunctionsRequest.h>
# include <aws/lambda/model/UpdateFunctionCodeRequest.h>
# include <aws/lambda/model/UpdateFunctionConfigurationRequest.h>
# include <aws/core/utils/HashingUtils.h>
# include <fstream>
# include "lambda_samples.h"
2023-06-27 12:03:19 -04:00
# define USE_CPP_LAMBDA_FUNCTION 0 // For building instructions, see cpp_lambda/README.md.
2022-12-08 15:49:42 -05:00
namespace AwsDoc {
namespace Lambda {
static Aws : : String ROLE_NAME ( " doc_example_lambda_calculator_cpp_role " ) ;
static Aws : : String LAMBDA_NAME ( " doc_example_lambda_calculator_cpp " ) ;
static Aws : : String LAMBDA_DESCRIPTION ( " AWS C++ Get started with functions. " ) ;
2023-06-27 12:03:19 -04:00
2023-01-20 12:36:13 -05:00
# if USE_CPP_LAMBDA_FUNCTION
static Aws : : String LAMBDA_HANDLER_NAME (
" cpp_lambda_calculator " ) ;
static Aws : : String INCREMENT_LAMBDA_CODE (
2023-06-27 12:03:19 -04:00
SOURCE_DIR " /cpp_lambda/increment/build/cpp_lambda_increment.zip " ) ;
2023-01-20 12:36:13 -05:00
static Aws : : String CALCULATOR_LAMBDA_CODE (
2023-06-27 12:03:19 -04:00
SOURCE_DIR " /cpp_lambda/calculator/build/cpp_lambda_calculator.zip " ) ;
# else // !USE_CPP_LAMBDA_FUNCTION
2022-12-08 15:49:42 -05:00
static Aws : : String LAMBDA_HANDLER_NAME (
" doc_example_lambda_calculator.lambda_handler " ) ;
static Aws : : String INCREMENT_LAMBDA_CODE (
SOURCE_DIR " /doc_example_lambda_increment.zip " ) ;
static Aws : : String CALCULATOR_LAMBDA_CODE (
SOURCE_DIR " /doc_example_lambda_calculator.zip " ) ;
2023-06-27 12:03:19 -04:00
# endif // USE_CPP_LAMBDA_FUNCTION
2022-12-08 15:49:42 -05:00
static Aws : : String ROLE_POLICY_ARN (
" arn:aws:iam::aws:policy/service-role/AWSLambdaBasicExecutionRole " ) ;
Aws : : String INCREMENT_RESUlT_PREFIX ( " The result of the increment is " ) ;
Aws : : String ARITHMETIC_RESUlT_PREFIX ( " The result of the operation " ) ;
//! Routine which invokes a Lambda function and returns the result.
/*!
\param jsonPayload: Payload for invoke function.
\param logType: Log type setting for invoke function.
\param invokeResult: InvokeResult object to receive the result.
\param client: Lambda client.
\return bool: Successful completion.
*/
static bool invokeLambdaFunction ( const Aws : : Utils : : Json : : JsonValue & jsonPayload ,
Aws : : Lambda : : Model : : LogType logType ,
Aws : : Lambda : : Model : : InvokeResult & invokeResult ,
const Aws : : Lambda : : LambdaClient & client ) ;
//! Routine which creates an IAM role, attaches an IAM policy and returns the
//! role Amazon Resource Name (ARN).
/*!
\param roleARN: String to receive the IAM role ARN.
\param clientConfig: AWS client configuration.
\return bool: Successful completion.
*/
static bool getIamRoleArn ( Aws : : String & roleARN ,
const Aws : : Client : : ClientConfiguration & clientConfig ) ;
//! Routine which deletes the IAM role.
/*!
\param clientConfig: AWS client configuration.
\return bool: Successful completion.
*/
static bool deleteIamRole ( const Aws : : Client : : ClientConfiguration & clientConfig ) ;
2023-06-27 12:03:19 -04:00
//! Routine which deletes the Lambda function.
/*!
\param client: A LambdaClient instance.
\return bool: Successful completion.
*/
static bool deleteLambdaFunction ( const Aws : : Lambda : : LambdaClient & client ) ;
2022-12-08 15:49:42 -05:00
//! Command line prompt/response utility function.
/*!
\param string: A question prompt.
\param test: Test function for response.
\return Aws::String: User's response.
*/
static Aws : : String askQuestion ( const Aws : : String & string ,
const std : : function < bool (
Aws : : String ) > & test = [ ] (
const Aws : : String & ) - > bool { return true ; } ) ;
//! Command line prompt/response utility function for an integer result.
/*!
\param string: A question prompt.
\return int: User's response.
*/
static int askQuestionForInt ( const Aws : : String & string ) ;
//! Command line prompt/response utility function for an int result confined to
//! a range.
/*!
\param string: A question prompt.
\param low: Low inclusive.
\param high: High inclusive.
\return int: User's response.
*/
static int askQuestionForIntRange ( const Aws : : String & string , int low ,
int high ) ;
} // Lambda
} // AwsDoc
// snippet-start:[cpp.example_code.lambda.get_started_with_functions]
//! Get started with functions scenario.
/*!
\param clientConfig: AWS client configuration.
\return bool: Successful completion.
*/
bool AwsDoc : : Lambda : : getStartedWithFunctionsScenario (
const Aws : : Client : : ClientConfiguration & clientConfig ) {
// snippet-start:[cpp.example_code.lambda.lambda_client]
Aws : : Lambda : : LambdaClient client ( clientConfig ) ;
// snippet-end:[cpp.example_code.lambda.lambda_client]
// 1. Create an AWS Identity and Access Management (IAM) role for Lambda function.
Aws : : String roleArn ;
if ( ! getIamRoleArn ( roleArn , clientConfig ) ) {
return false ;
}
// 2. Create a Lambda function.
int seconds = 0 ;
do {
2024-02-15 12:03:43 -05:00
// snippet-start:[cpp.example_code.lambda.CreateFunction]
2022-12-08 15:49:42 -05:00
Aws : : Lambda : : Model : : CreateFunctionRequest request ;
request . SetFunctionName ( LAMBDA_NAME ) ;
request . SetDescription ( LAMBDA_DESCRIPTION ) ; // Optional.
2023-01-20 12:36:13 -05:00
# if USE_CPP_LAMBDA_FUNCTION
request . SetRuntime ( Aws : : Lambda : : Model : : Runtime : : provided_al2 ) ;
request . SetTimeout ( 15 ) ;
request . SetMemorySize ( 128 ) ;
// Assume the AWS Lambda function was built in Docker with same architecture
// as this code.
# if defined(__x86_64__)
request . SetArchitectures ( { Aws : : Lambda : : Model : : Architecture : : x86_64 } ) ;
# elif defined(__aarch64__)
2023-06-27 12:03:19 -04:00
request . SetArchitectures ( { Aws : : Lambda : : Model : : Architecture : : arm64 } ) ;
2023-01-20 12:36:13 -05:00
# else
# error "Unimplemented architecture"
# endif // defined(architecture)
# else
2024-10-22 16:22:44 -04:00
request . SetRuntime ( Aws : : Lambda : : Model : : Runtime : : python3_9 ) ;
2023-01-20 12:36:13 -05:00
# endif
2022-12-08 15:49:42 -05:00
request . SetRole ( roleArn ) ;
request . SetHandler ( LAMBDA_HANDLER_NAME ) ;
request . SetPublish ( true ) ;
Aws : : Lambda : : Model : : FunctionCode code ;
std : : ifstream ifstream ( INCREMENT_LAMBDA_CODE . c_str ( ) ,
std : : ios_base : : in | std : : ios_base : : binary ) ;
2023-06-27 12:03:19 -04:00
if ( ! ifstream . is_open ( ) ) {
std : : cerr < < " Error opening file " < < INCREMENT_LAMBDA_CODE < < " . " < < std : : endl ;
# if USE_CPP_LAMBDA_FUNCTION
std : : cerr
< < " The cpp Lambda function must be built following the instructions in the cpp_lambda/README.md file. "
< < std : : endl ;
# endif
deleteIamRole ( clientConfig ) ;
return false ;
}
2022-12-08 15:49:42 -05:00
Aws : : StringStream buffer ;
buffer < < ifstream . rdbuf ( ) ;
code . SetZipFile ( Aws : : Utils : : ByteBuffer ( ( unsigned char * ) buffer . str ( ) . c_str ( ) ,
buffer . str ( ) . length ( ) ) ) ;
request . SetCode ( code ) ;
Aws : : Lambda : : Model : : CreateFunctionOutcome outcome = client . CreateFunction (
request ) ;
if ( outcome . IsSuccess ( ) ) {
std : : cout < < " The lambda function was successfully created. " < < seconds
< < " seconds elapsed. " < < std : : endl ;
break ;
}
2024-02-15 12:03:43 -05:00
// snippet-end:[cpp.example_code.lambda.CreateFunction]
2022-12-08 15:49:42 -05:00
else if ( outcome . GetError ( ) . GetErrorType ( ) = =
Aws : : Lambda : : LambdaErrors : : INVALID_PARAMETER_VALUE & &
outcome . GetError ( ) . GetMessage ( ) . find ( " role " ) > = 0 ) {
if ( ( seconds % 5 ) = = 0 ) { // Log status every 10 seconds.
std : : cout
< < " Waiting for the IAM role to become available as a CreateFunction parameter. "
< < seconds
< < " seconds elapsed. " < < std : : endl ;
2023-01-20 12:36:13 -05:00
std : : cout < < outcome . GetError ( ) . GetMessage ( ) < < std : : endl ;
2022-12-08 15:49:42 -05:00
}
}
// snippet-start:[cpp.example_code.lambda.create_function2]
else {
std : : cerr < < " Error with CreateFunction. "
< < outcome . GetError ( ) . GetMessage ( )
< < std : : endl ;
deleteIamRole ( clientConfig ) ;
return false ;
}
// snippet-end:[cpp.example_code.lambda.create_function2]
+ + seconds ;
std : : this_thread : : sleep_for ( std : : chrono : : seconds ( 1 ) ) ;
} while ( 60 > seconds ) ;
std : : cout < < " The current Lambda function increments 1 by an input. " < < std : : endl ;
// 3. Invoke the Lambda function.
{
2023-06-27 12:03:19 -04:00
int increment = askQuestionForInt ( " Enter an increment integer: " ) ;
2022-12-08 15:49:42 -05:00
Aws : : Lambda : : Model : : InvokeResult invokeResult ;
Aws : : Utils : : Json : : JsonValue jsonPayload ;
jsonPayload . WithString ( " action " , " increment " ) ;
jsonPayload . WithInteger ( " number " , increment ) ;
if ( invokeLambdaFunction ( jsonPayload , Aws : : Lambda : : Model : : LogType : : Tail ,
invokeResult , client ) ) {
Aws : : Utils : : Json : : JsonValue jsonValue ( invokeResult . GetPayload ( ) ) ;
Aws : : Map < Aws : : String , Aws : : Utils : : Json : : JsonView > values =
jsonValue . View ( ) . GetAllObjects ( ) ;
auto iter = values . find ( " result " ) ;
if ( iter ! = values . end ( ) & & iter - > second . IsIntegerType ( ) ) {
{
std : : cout < < INCREMENT_RESUlT_PREFIX
< < iter - > second . AsInteger ( ) < < std : : endl ;
}
}
else {
std : : cout < < " There was an error in execution. Here is the log. "
< < std : : endl ;
Aws : : Utils : : ByteBuffer buffer = Aws : : Utils : : HashingUtils : : Base64Decode (
invokeResult . GetLogResult ( ) ) ;
std : : cout < < " With log " < < buffer . GetUnderlyingData ( ) < < std : : endl ;
}
}
}
std : : cout
< < " The Lambda function will now be updated with new code. Press return to continue, " ;
Aws : : String answer ;
std : : getline ( std : : cin , answer ) ;
// 4. Update the Lambda function code.
{
2024-02-15 12:03:43 -05:00
// snippet-start:[cpp.example_code.lambda.UpdateFunctionCode]
2022-12-08 15:49:42 -05:00
Aws : : Lambda : : Model : : UpdateFunctionCodeRequest request ;
request . SetFunctionName ( LAMBDA_NAME ) ;
std : : ifstream ifstream ( CALCULATOR_LAMBDA_CODE . c_str ( ) ,
std : : ios_base : : in | std : : ios_base : : binary ) ;
2023-06-27 12:03:19 -04:00
if ( ! ifstream . is_open ( ) ) {
std : : cerr < < " Error opening file " < < INCREMENT_LAMBDA_CODE < < " . " < < std : : endl ;
# if USE_CPP_LAMBDA_FUNCTION
std : : cerr
< < " The cpp Lambda function must be built following the instructions in the cpp_lambda/README.md file. "
< < std : : endl ;
# endif
deleteLambdaFunction ( client ) ;
deleteIamRole ( clientConfig ) ;
return false ;
}
2022-12-08 15:49:42 -05:00
Aws : : StringStream buffer ;
buffer < < ifstream . rdbuf ( ) ;
request . SetZipFile (
Aws : : Utils : : ByteBuffer ( ( unsigned char * ) buffer . str ( ) . c_str ( ) ,
buffer . str ( ) . length ( ) ) ) ;
request . SetPublish ( true ) ;
Aws : : Lambda : : Model : : UpdateFunctionCodeOutcome outcome = client . UpdateFunctionCode (
request ) ;
if ( outcome . IsSuccess ( ) ) {
std : : cout < < " The lambda code was successfully updated. " < < std : : endl ;
}
else {
std : : cerr < < " Error with Lambda::UpdateFunctionCode. "
< < outcome . GetError ( ) . GetMessage ( )
< < std : : endl ;
}
2024-02-15 12:03:43 -05:00
// snippet-end:[cpp.example_code.lambda.UpdateFunctionCode]
2022-12-08 15:49:42 -05:00
}
std : : cout
< < " This function uses an environment variable to control the logging level. "
< < std : : endl ;
std : : cout
< < " UpdateFunctionConfiguration will be used to set the LOG_LEVEL to DEBUG. "
< < std : : endl ;
seconds = 0 ;
// 5. Update the Lambda function configuration.
do {
+ + seconds ;
std : : this_thread : : sleep_for ( std : : chrono : : seconds ( 1 ) ) ;
2024-02-15 12:03:43 -05:00
// snippet-start:[cpp.example_code.lambda.UpdateFunctionConfiguration]
2022-12-08 15:49:42 -05:00
Aws : : Lambda : : Model : : UpdateFunctionConfigurationRequest request ;
request . SetFunctionName ( LAMBDA_NAME ) ;
Aws : : Lambda : : Model : : Environment environment ;
environment . AddVariables ( " LOG_LEVEL " , " DEBUG " ) ;
request . SetEnvironment ( environment ) ;
Aws : : Lambda : : Model : : UpdateFunctionConfigurationOutcome outcome = client . UpdateFunctionConfiguration (
request ) ;
if ( outcome . IsSuccess ( ) ) {
std : : cout < < " The lambda configuration was successfully updated. "
< < std : : endl ;
break ;
}
2024-02-15 12:03:43 -05:00
// snippet-end:[cpp.example_code.lambda.UpdateFunctionConfiguration]
2022-12-08 15:49:42 -05:00
// RESOURCE_IN_USE: function code update not completed.
else if ( outcome . GetError ( ) . GetErrorType ( ) ! =
Aws : : Lambda : : LambdaErrors : : RESOURCE_IN_USE ) {
if ( ( seconds % 10 ) = = 0 ) { // Log status every 10 seconds.
std : : cout < < " Lambda function update in progress . After " < < seconds
< < " seconds elapsed. " < < std : : endl ;
}
}
// snippet-start:[cpp.example_code.lambda.update_function_configuration2]
else {
std : : cerr < < " Error with Lambda::UpdateFunctionConfiguration. "
< < outcome . GetError ( ) . GetMessage ( )
< < std : : endl ;
}
// snippet-end:[cpp.example_code.lambda.update_function_configuration2]
} while ( 0 < seconds ) ;
if ( 0 > seconds ) {
std : : cerr < < " Function failed to become active. " < < std : : endl ;
}
else {
std : : cout < < " Updated function active after " < < seconds < < " seconds. "
< < std : : endl ;
}
std : : cout
< < " \n The new code applies an arithmetic operator to two variables, x an y. "
< < std : : endl ;
std : : vector < Aws : : String > operators = { " plus " , " minus " , " times " , " divided-by " } ;
for ( size_t i = 0 ; i < operators . size ( ) ; + + i ) {
std : : cout < < " " < < i + 1 < < " " < < operators [ i ] < < std : : endl ;
}
// 6. Invoke the updated Lambda function.
do {
int operatorIndex = askQuestionForIntRange ( " Select an operator index 1 - 4 " , 1 ,
4 ) ;
int x = askQuestionForInt ( " Enter an integer for the x value " ) ;
int y = askQuestionForInt ( " Enter an integer for the y value " ) ;
Aws : : Utils : : Json : : JsonValue calculateJsonPayload ;
calculateJsonPayload . WithString ( " action " , operators [ operatorIndex - 1 ] ) ;
calculateJsonPayload . WithInteger ( " x " , x ) ;
calculateJsonPayload . WithInteger ( " y " , y ) ;
Aws : : Lambda : : Model : : InvokeResult calculatedResult ;
if ( invokeLambdaFunction ( calculateJsonPayload ,
Aws : : Lambda : : Model : : LogType : : Tail ,
calculatedResult , client ) ) {
Aws : : Utils : : Json : : JsonValue jsonValue ( calculatedResult . GetPayload ( ) ) ;
Aws : : Map < Aws : : String , Aws : : Utils : : Json : : JsonView > values =
jsonValue . View ( ) . GetAllObjects ( ) ;
auto iter = values . find ( " result " ) ;
if ( iter ! = values . end ( ) & & iter - > second . IsIntegerType ( ) ) {
std : : cout < < ARITHMETIC_RESUlT_PREFIX < < x < < " "
< < operators [ operatorIndex - 1 ] < < " "
< < y < < " is " < < iter - > second . AsInteger ( ) < < std : : endl ;
}
else if ( iter ! = values . end ( ) & & iter - > second . IsFloatingPointType ( ) ) {
std : : cout < < ARITHMETIC_RESUlT_PREFIX < < x < < " "
< < operators [ operatorIndex - 1 ] < < " "
< < y < < " is " < < iter - > second . AsDouble ( ) < < std : : endl ;
}
else {
std : : cout < < " There was an error in execution. Here is the log. "
< < std : : endl ;
Aws : : Utils : : ByteBuffer buffer = Aws : : Utils : : HashingUtils : : Base64Decode (
calculatedResult . GetLogResult ( ) ) ;
std : : cout < < " With log " < < buffer . GetUnderlyingData ( ) < < std : : endl ;
}
}
answer = askQuestion ( " Would you like to try another operation? (y/n) " ) ;
} while ( answer = = " y " ) ;
std : : cout
< < " A list of the lambda functions will be retrieved. Press return to continue, " ;
std : : getline ( std : : cin , answer ) ;
// 7. List the Lambda functions.
2024-02-15 12:03:43 -05:00
// snippet-start:[cpp.example_code.lambda.ListFunctions]
2022-12-08 15:49:42 -05:00
std : : vector < Aws : : String > functions ;
Aws : : String marker ;
do {
Aws : : Lambda : : Model : : ListFunctionsRequest request ;
if ( ! marker . empty ( ) ) {
request . SetMarker ( marker ) ;
}
Aws : : Lambda : : Model : : ListFunctionsOutcome outcome = client . ListFunctions (
request ) ;
if ( outcome . IsSuccess ( ) ) {
const Aws : : Lambda : : Model : : ListFunctionsResult & result = outcome . GetResult ( ) ;
std : : cout < < result . GetFunctions ( ) . size ( )
< < " lambda functions were retrieved. " < < std : : endl ;
for ( const Aws : : Lambda : : Model : : FunctionConfiguration & functionConfiguration : result . GetFunctions ( ) ) {
functions . push_back ( functionConfiguration . GetFunctionName ( ) ) ;
std : : cout < < functions . size ( ) < < " "
< < functionConfiguration . GetDescription ( ) < < std : : endl ;
std : : cout < < " "
< < Aws : : Lambda : : Model : : RuntimeMapper : : GetNameForRuntime (
functionConfiguration . GetRuntime ( ) ) < < " : "
< < functionConfiguration . GetHandler ( )
< < std : : endl ;
}
marker = result . GetNextMarker ( ) ;
}
else {
std : : cerr < < " Error with Lambda::ListFunctions. "
< < outcome . GetError ( ) . GetMessage ( )
< < std : : endl ;
}
} while ( ! marker . empty ( ) ) ;
2024-02-15 12:03:43 -05:00
// snippet-end:[cpp.example_code.lambda.ListFunctions]
2022-12-08 15:49:42 -05:00
// 8. Get a Lambda function.
if ( ! functions . empty ( ) ) {
std : : stringstream question ;
question < < " Choose a function to retrieve between 1 and " < < functions . size ( )
< < " " ;
int functionIndex = askQuestionForIntRange ( question . str ( ) , 1 ,
static_cast < int > ( functions . size ( ) ) ) ;
Aws : : String functionName = functions [ functionIndex - 1 ] ;
2024-02-15 12:03:43 -05:00
// snippet-start:[cpp.example_code.lambda.GetFunction]
2022-12-08 15:49:42 -05:00
Aws : : Lambda : : Model : : GetFunctionRequest request ;
request . SetFunctionName ( functionName ) ;
Aws : : Lambda : : Model : : GetFunctionOutcome outcome = client . GetFunction ( request ) ;
if ( outcome . IsSuccess ( ) ) {
std : : cout < < " Function retrieve. \n " < <
outcome . GetResult ( ) . GetConfiguration ( ) . Jsonize ( ) . View ( ) . WriteReadable ( )
< < std : : endl ;
}
else {
std : : cerr < < " Error with Lambda::GetFunction. "
< < outcome . GetError ( ) . GetMessage ( )
< < std : : endl ;
}
2024-02-15 12:03:43 -05:00
// snippet-end:[cpp.example_code.lambda.GetFunction]
2022-12-08 15:49:42 -05:00
}
std : : cout < < " The resources will be deleted. Press return to continue, " ;
std : : getline ( std : : cin , answer ) ;
// 9. Delete the Lambda function.
2023-06-27 12:03:19 -04:00
bool result = deleteLambdaFunction ( client ) ;
2022-12-08 15:49:42 -05:00
// 10. Delete the IAM role.
2023-06-27 12:03:19 -04:00
return result & & deleteIamRole ( clientConfig ) ;
2022-12-08 15:49:42 -05:00
}
//! Routine which invokes a Lambda function and returns the result.
/*!
\param jsonPayload: Payload for invoke function.
\param logType: Log type setting for invoke function.
\param invokeResult: InvokeResult object to receive the result.
\param client: Lambda client.
\return bool: Successful completion.
*/
bool
AwsDoc : : Lambda : : invokeLambdaFunction ( const Aws : : Utils : : Json : : JsonValue & jsonPayload ,
Aws : : Lambda : : Model : : LogType logType ,
Aws : : Lambda : : Model : : InvokeResult & invokeResult ,
const Aws : : Lambda : : LambdaClient & client ) {
int seconds = 0 ;
bool result = false ;
/*
* In this example, the Invoke function can be called before recently created resources are
* available. The Invoke function is called repeatedly until the resources are
* available.
*/
do {
2024-02-15 12:03:43 -05:00
// snippet-start:[cpp.example_code.lambda.Invoke]
2022-12-08 15:49:42 -05:00
Aws : : Lambda : : Model : : InvokeRequest request ;
request . SetFunctionName ( LAMBDA_NAME ) ;
request . SetLogType ( logType ) ;
std : : shared_ptr < Aws : : IOStream > payload = Aws : : MakeShared < Aws : : StringStream > (
" FunctionTest " ) ;
* payload < < jsonPayload . View ( ) . WriteReadable ( ) ;
request . SetBody ( payload ) ;
request . SetContentType ( " application/json " ) ;
Aws : : Lambda : : Model : : InvokeOutcome outcome = client . Invoke ( request ) ;
if ( outcome . IsSuccess ( ) ) {
invokeResult = std : : move ( outcome . GetResult ( ) ) ;
result = true ;
break ;
}
2024-02-15 12:03:43 -05:00
// snippet-end:[cpp.example_code.lambda.Invoke]
2022-12-08 15:49:42 -05:00
// ACCESS_DENIED: because the role is not available yet.
// RESOURCE_CONFLICT: because the Lambda function is being created or updated.
else if ( ( outcome . GetError ( ) . GetErrorType ( ) = =
Aws : : Lambda : : LambdaErrors : : ACCESS_DENIED ) | |
( outcome . GetError ( ) . GetErrorType ( ) = =
Aws : : Lambda : : LambdaErrors : : RESOURCE_CONFLICT ) ) {
if ( ( seconds % 5 ) = = 0 ) { // Log status every 10 seconds.
std : : cout < < " Waiting for the invoke api to be available, status " < <
( ( outcome . GetError ( ) . GetErrorType ( ) = =
Aws : : Lambda : : LambdaErrors : : ACCESS_DENIED ?
" ACCESS_DENIED " : " RESOURCE_CONFLICT " ) ) < < " . " < < seconds
< < " seconds elapsed. " < < std : : endl ;
}
}
// snippet-start:[cpp.example_code.lambda.invoke_function2]
else {
std : : cerr < < " Error with Lambda::InvokeRequest. "
< < outcome . GetError ( ) . GetMessage ( )
< < std : : endl ;
break ;
}
// snippet-end:[cpp.example_code.lambda.invoke_function2]
+ + seconds ;
std : : this_thread : : sleep_for ( std : : chrono : : seconds ( 1 ) ) ;
} while ( seconds < 60 ) ;
return result ;
}
// snippet-end:[cpp.example_code.lambda.get_started_with_functions]
/*
*
* main function
*
* Usage: 'run_get_started_with_functions_scenario'
*
*/
# ifndef TESTING_BUILD
int main ( int argc , const char * argv [ ] ) {
( void ) argc ; // Suppress unused warnings.
( void ) argv ; // Suppress unused warnings.
Aws : : SDKOptions options ;
InitAPI ( options ) ;
{
// snippet-start:[cpp.example_code.lambda.lambda_configuration]
Aws : : Client : : ClientConfiguration clientConfig ;
// Optional: Set to the AWS Region in which the bucket was created (overrides config file).
// clientConfig.region = "us-east-1";
// snippet-end:[cpp.example_code.lambda.lambda_configuration]
AwsDoc : : Lambda : : getStartedWithFunctionsScenario ( clientConfig ) ;
}
ShutdownAPI ( options ) ;
return 0 ;
}
# endif // TESTING_BUILD
//! Command line prompt/response utility function.
/*!
\param string: A question prompt.
\param test: Test function for response.
\return Aws::String: User's response.
*/
Aws : : String AwsDoc : : Lambda : : askQuestion ( const Aws : : String & string ,
const std : : function < bool (
Aws : : String ) > & test ) {
Aws : : String result ;
do {
std : : cout < < string ;
std : : getline ( std : : cin , result ) ;
if ( result . empty ( ) ) {
std : : cout < < " Please enter some text. " < < std : : endl ;
}
if ( ! test ( result ) ) {
result . clear ( ) ;
}
} while ( result . empty ( ) ) ;
return result ;
}
//! Command line prompt/response utility function for an integer result.
/*!
\sa askQuestionForInt()
\param string: A question prompt.
\return int: User's response.
*/
int AwsDoc : : Lambda : : askQuestionForInt ( const Aws : : String & string ) {
Aws : : String resultString = askQuestion ( string ,
[ ] ( const Aws : : String & string1 ) - > bool {
try {
( void ) std : : stoi ( string1 ) ;
return true ;
}
catch ( const std : : invalid_argument & ) {
return false ;
}
} ) ;
int result = 0 ;
try {
result = std : : stoi ( resultString ) ;
}
catch ( const std : : invalid_argument & ) {
std : : cerr < < " askQuestionForInt string not an int "
< < resultString < < std : : endl ;
}
return result ;
}
//! Command line prompt/response utility function for an int result confined to
//! a range.
/*!
\sa askQuestionForIntRange()
\param string: A question prompt.
\param low: Low inclusive.
\param high: High inclusive.
\return int: User's response.
*/
int AwsDoc : : Lambda : : askQuestionForIntRange ( const Aws : : String & string , int low ,
int high ) {
Aws : : String resultString = askQuestion ( string , [ low , high ] (
const Aws : : String & string1 ) - > bool {
try {
int number = std : : stoi ( string1 ) ;
return number > = low & & number < = high ;
}
catch ( const std : : invalid_argument & ) {
return false ;
}
} ) ;
int result = 0 ;
try {
result = std : : stoi ( resultString ) ;
}
catch ( const std : : invalid_argument & ) {
std : : cerr < < " askQuestionForFloatRange string not an int "
< < resultString < < std : : endl ;
}
return result ;
}
//! Routine which creates an IAM role, attaches an IAM policy and returns the
//! role Amazon Resource Name (ARN).
/*!
\param roleARN: String to receive the IAM role ARN.
\param clientConfig: AWS client configuration.
\return bool: Successful completion.
*/
bool AwsDoc : : Lambda : : getIamRoleArn ( Aws : : String & roleARN ,
const Aws : : Client : : ClientConfiguration & clientConfig ) {
Aws : : IAM : : IAMClient client ( clientConfig ) ;
{
Aws : : IAM : : Model : : CreateRoleRequest createRoleRequest ;
createRoleRequest . SetRoleName ( ROLE_NAME ) ;
createRoleRequest . SetAssumeRolePolicyDocument ( R " ({
" Version " : " 2012-10-17 " ,
" Statement " : [
{
" Effect " : " Allow " ,
" Principal " : {
" Service " : " lambda.amazonaws.com "
} ,
" Action " : " sts:AssumeRole "
}
]
} ) " );
Aws : : IAM : : Model : : CreateRoleOutcome createRoleOutcome = client . CreateRole (
createRoleRequest ) ;
if ( createRoleOutcome . IsSuccess ( ) ) {
std : : cout < < " IAM::CreateRole was successful. " < < std : : endl ;
roleARN = createRoleOutcome . GetResult ( ) . GetRole ( ) . GetArn ( ) ;
}
else if ( createRoleOutcome . GetError ( ) . GetErrorType ( ) = =
Aws : : IAM : : IAMErrors : : ENTITY_ALREADY_EXISTS ) {
Aws : : IAM : : Model : : GetRoleRequest request ;
request . SetRoleName ( ROLE_NAME ) ;
Aws : : IAM : : Model : : GetRoleOutcome outcome = client . GetRole ( request ) ;
if ( outcome . IsSuccess ( ) ) {
std : : cout < < " IAM::GetRole was successful. " < < std : : endl ;
roleARN = outcome . GetResult ( ) . GetRole ( ) . GetArn ( ) ;
return true ;
}
else {
std : : cerr < < " Error with IAM::GetRole. "
< < outcome . GetError ( ) . GetMessage ( )
< < std : : endl ;
return false ;
}
}
else {
std : : cerr < < " Error with IAM::CreateRole. "
< < createRoleOutcome . GetError ( ) . GetMessage ( )
< < std : : endl ;
return false ;
}
}
{
Aws : : IAM : : Model : : AttachRolePolicyRequest attachRolePolicyRequest ;
attachRolePolicyRequest . SetRoleName ( ROLE_NAME ) ;
attachRolePolicyRequest . WithPolicyArn ( ROLE_POLICY_ARN ) ;
Aws : : IAM : : Model : : AttachRolePolicyOutcome attachRolePolicyOutcome = client . AttachRolePolicy (
attachRolePolicyRequest ) ;
if ( attachRolePolicyOutcome . IsSuccess ( ) ) {
std : : cout < < " Successfully attached the role policy " < < std : : endl ;
}
else {
std : : cerr < < " Error creating policy. " < <
attachRolePolicyOutcome . GetError ( ) . GetMessage ( ) < < std : : endl ;
return false ;
}
}
return true ;
}
//! Routine which deletes the IAM role.
/*!
\param roleARN: String to receive the IAM role ARN.
\param clientConfig: AWS client configuration.
\return bool: Successful completion.
*/
bool
AwsDoc : : Lambda : : deleteIamRole ( const Aws : : Client : : ClientConfiguration & clientConfig ) {
Aws : : IAM : : IAMClient client ( clientConfig ) ;
// Detach the policy from the role.
bool result = true ;
{
Aws : : IAM : : Model : : DetachRolePolicyRequest request ;
request . SetPolicyArn ( ROLE_POLICY_ARN ) ;
request . SetRoleName ( ROLE_NAME ) ;
Aws : : IAM : : Model : : DetachRolePolicyOutcome outcome = client . DetachRolePolicy (
request ) ;
if ( outcome . IsSuccess ( ) ) {
std : : cout < < " Successfully detached the IAM role policy. " < < std : : endl ;
}
else {
std : : cerr < < " Error Detaching policy from roles. " < <
outcome . GetError ( ) . GetMessage ( ) < < std : : endl ;
result = false ;
}
}
// Delete the role.
Aws : : IAM : : Model : : DeleteRoleRequest request ;
request . SetRoleName ( ROLE_NAME ) ;
Aws : : IAM : : Model : : DeleteRoleOutcome outcome = client . DeleteRole ( request ) ;
if ( ! outcome . IsSuccess ( ) ) {
std : : cerr < < " Error deleting role. " < <
outcome . GetError ( ) . GetMessage ( ) < < std : : endl ;
result = false ;
}
else {
std : : cout < < " Successfully deleted the IAM role. " < < std : : endl ;
}
return result ;
}
2023-06-27 12:03:19 -04:00
//! Routine which deletes the Lambda function.
/*!
\param client: A LambdaClient instance.
\param clientConfig: AWS client configuration.
\return bool: Successful completion.
*/
bool AwsDoc : : Lambda : : deleteLambdaFunction ( const Aws : : Lambda : : LambdaClient & client ) {
2024-02-15 12:03:43 -05:00
// snippet-start:[cpp.example_code.lambda.DeleteFunction]
2023-06-27 12:03:19 -04:00
Aws : : Lambda : : Model : : DeleteFunctionRequest request ;
request . SetFunctionName ( LAMBDA_NAME ) ;
Aws : : Lambda : : Model : : DeleteFunctionOutcome outcome = client . DeleteFunction (
request ) ;
if ( outcome . IsSuccess ( ) ) {
std : : cout < < " The lambda function was successfully deleted. " < < std : : endl ;
}
else {
std : : cerr < < " Error with Lambda::DeleteFunction. "
< < outcome . GetError ( ) . GetMessage ( )
< < std : : endl ;
}
2024-02-15 12:03:43 -05:00
// snippet-end:[cpp.example_code.lambda.DeleteFunction]
2023-06-27 12:03:19 -04:00
return outcome . IsSuccess ( ) ;
}
2022-12-08 15:49:42 -05:00
