aws_yash v1.0.6
godspeed-plugin-aws-as-datasource
Welcome to the backbone of the cloud—the Amazon Web Services (AWS). Renowned for its unparalleled scalability and reliability, AWS stands as a juggernaut in cloud computing. Empowering businesses with a vast array of services, from storage to machine learning, AWS is the conduit for innovation in the digital realm. Dive into the future of computing with AWS as your steadfast and cutting-edge data source.
A brief description of how to use aws plug-in in our godspeed framework as Data Source as Event Source.
Steps to use aws plug-in in godspeed framework:
Add plugin using CLI
Example usage (listObjects):
- Update configuration file based on your requirements in
Datasource/aws.yaml
.
aws config ( src/datasources/aws.yaml )
type: aws
region: "ap-south-1"
bucket_name: "godspeed-test"
accessKeyId: "AKIC4KQJJFGY3NDQ2TPY"
secretAccessKey: "lXxTDaVZyv+dwMn2PepJ9gyd1IotfX/voBmggu6E"
aws event for list Objects ( src/events/aws_event.yaml )
In the event, we establish HTTP endpoint that accepts json objects in request body. When this endpoint is invoked, it triggers the aws_list
function. This function, in turn, takes the input arguments and performs the task of creating new objects to the specified aws file.
# event for create
"http.post./aws":
fn: aws_list
body:
type: object
responses:
200:
application/json:
aws workflow for create a new user ( src/functions/aws_list.yaml )
In workflow we need to mension datasource.aws.${method}
as function (fn) to perform operations in this case datasource.aws.listObjects
.
id: aws
tasks:
- id: aws_list
fn: datasource.aws.listObjects
args:
params: <% inputs.body.params %>
Plugin Commands (Operations List)
- Bucket
- Key
- UploadId
Command API Reference / Input / Output
required params
- Bucket
- Key
- MultipartUpload
- Parts
Command API Reference / Input / Output
required params
- Bucket
- CopySource
- Key
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
- Key
Command API Reference / Input / Output
required params
- Bucket
Command API Reference / Input / Output
- Bucket
- Id
Command API Reference / Input / Output
required params
- Bucket
Command API Reference / Input / Output
required params
- Bucket
Command API Reference / Input / Output
- Bucket
- Id
Command API Reference / Input / Output
- Bucket
- Id
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
- Id
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
required params
- Bucket
- Key
Command API Reference / Input / Output
require params
- Bucket
- Delete
Objects
Command API Reference / Input / Output
required params
- Bucket
- Key
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
required params
- Bucket
- Id
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
required params
- Bucket
- Id
Command API Reference / Input / Output
- Bucket
- Key
Command API Reference / Input / Output
required params
- Bucket
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
- Id
Command API Reference / Input / Output
Bucket
Command API Reference / Input / Output
Bucket
Command API Reference / Input / Output
Bucket
Command API Reference / Input / Output
Bucket
Command API Reference / Input / Output
Bucket
Command API Reference / Input / Output
Bucket
Command API Reference / Input / Output
Bucket
Command API Reference / Input / Output
Bucket
Command API Reference / Input / Output
Bucket
Command API Reference / Input / Output
- Bucket
- key
Command API Reference / Input / Output
- Bucket
- key
Command API Reference / Input / Output
- Bucket
- key
Command API Reference / Input / Output
- Bucket
- key
Command API Reference / Input / Output
- Bucket
- key
Command API Reference / Input / Output
- Bucket
- key
Command API Reference / Input / Output
- Bucket
- key
Command API Reference / Input / Output
- Bucket
- key
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
required
- (No specific parameters)
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
- Bucket
Command API Reference / Input / Output
required params
- Bucket
- Key
- UploadId
Command API Reference / Input / Output
required params
- Bucket
- AccelerateConfiguration
- Status
Command API Reference / Input / Output
required params
- Bucket
- AccessControlPolicy
- Grants
- Owner
Command API Reference / Input / Output
- Bucket
- Id
- AnalyticsConfiguration
- StorageClassAnalysis
Command API Reference / Input / Output
- Bucket
- CORSConfiguration
- CORSRules
Command API Reference / Input / Output
required params
- Bucket
- ServerSideEncryptionConfiguration
- Rules
Command API Reference / Input / Output
- Bucket
- IntelligentTieringId
- IntelligentTieringConfiguration
- Status
- Tierings
- Days
- AccessTier
Command API Reference / Input / Output
required params
- Bucket
- Id
- InventoryConfiguration
- Destination
- IsEnabled
- Id
- IncludedObjectVersions
- Schedule
- OptionalFields
Command API Reference / Input / Output
required params
- Bucket
- LifecycleConfiguration
- Rules
Command API Reference / Input / Output
- Bucket
- BucketLoggingStatus
- LoggingEnabled
- TargetBucket
- TargetPrefix
Command API Reference / Input / Output
- Bucket
- Id
- MetricsConfiguration
- Id
- Filter
- StorageClassAnalysis
Command API Reference / Input / Output
required params
- Bucket
- NotificationConfiguration
- LambdaFunctionConfigurations
- QueueConfigurations
- TopicConfigurations
Command API Reference / Input / Output
requiredparams
- Bucket
- OwnershipControls
- Rules
Command API Reference / Input / Output
required params
- Bucket
- Policy
Command API Reference / Input / Output
- Bucket
- ReplicationConfiguration
- Role
- Rules
Command API Reference / Input / Output
required params
- Bucket
- RequestPaymentConfiguration
- Payer
Command API Reference / Input / Output
required params
- Bucket
- Tagging
Command API Reference / Input / Output
required params
- Bucket
- VersioningConfiguration
- Status
Command API Reference / Input / Output
required params
- Bucket
- WebsiteConfiguration
- ErrorDocument
- IndexDocument
- RedirectAllRequestsTo
- RoutingRules
Command API Reference / Input / Output
required params
- Bucket
- Key
- Body
Command API Reference / Input / Output
required params
- Bucket
- Key
- AccessControlPolicy
- Grants
- Owner
Command API Reference / Input / Output
- Bucket
- Key
- LegalHold
- Status
Command API Reference / Input / Output
- Bucket
- Key
- ObjectLockConfiguration
- ObjectLockEnabled
- Rule
Command API Reference / Input / Output
- Bucket
- Key
- Retention
- Mode
- RetainUntilDate
Command API Reference / Input / Output
- Bucket
- Key
- Tagging
Command API Reference / Input / Output
- Bucket
- PublicAccessBlockConfiguration
- BlockPublicAcls
- BlockPublicPolicy
- IgnorePublicAcls
- RestrictPublicBuckets
Command API Reference / Input / Output
- Bucket
- Key
- RestoreRequest
- Days
Command API Reference / Input / Output
- Bucket
- Key
- Expression
- ExpressionType
- InputSerialization
- OutputSerialization
Command API Reference / Input / Output
required params
- Bucket
- Key
- PartNumber
- UploadId
- Body
Command API Reference / Input / Output
required params
- Bucket
- CopySource
- CopySourceIfMatch
- CopySourceIfModifiedSince
- CopySourceIfNoneMatch
- CopySourceIfUnmodifiedSince
- CopySourceRange
- Key
- PartNumber
- UploadId
Command API Reference / Input / Output
- Bucket
- Key
- RequestRoute
- RequestToken
- StatusCode
- ResponseParameters
- ResponseHeaders
- ResponseBody
- PresignedUrl