aws

Documentation

Index

• Constants
• func ExecuteAthenaQuery(ctx context.Context, query string, campaignId int64) (map[string]string, [][]string, error)
• func MapAthenaResponse(response *athena.GetQueryResultsOutput) (map[string]string, [][]string)
• func PutObjectInBucket(data []byte, bucket string, key string) error
• func RunAthenaQuery(query string, campaignId int64) (*athena.GetQueryResultsOutput, error)

Constants

const (
	CONST_AWS_REGION                  = "ap-south-1"
	CONST_ATHENA_QUERY_SLEEP_DURATION = 2 // in seconds
	CONST_ATHENA_QUERY_SUCCESS        = "SUCCEEDED"
	CONST_ATHENA_QUERY_FAILED         = "FAILED"
	CONST_DATABASE_REWARDS_GATEWAY    = "rewards_gateway"
	CONST_NIL                         = "NIL"
)

Functions

func ExecuteAthenaQuery

func ExecuteAthenaQuery(ctx context.Context, query string, campaignId int64) (map[string]string, [][]string, error)

func MapAthenaResponse

func MapAthenaResponse(response *athena.GetQueryResultsOutput) (map[string]string, [][]string)

func PutObjectInBucket

func PutObjectInBucket(data []byte, bucket string, key string) error

func RunAthenaQuery

func RunAthenaQuery(query string, campaignId int64) (*athena.GetQueryResultsOutput, error)