The simplest, fastest way to integrate your app with an OAuth API
Creates a Step Function State Machine to publish a message to an SNS topic at a specific timestamp. The SNS topic delivers the message to this Pipedream source, and the source emits it as a new event.
Creates an SNS topic in your AWS account. Messages published to this topic are emitted from the Pipedream source.
The source subscribes to all emails delivered to a specific domain configured in AWS SES. When an email is sent to any address at the domain, this event source emits that email as a formatted event. These events can trigger a Pipedream workflow and can be consumed via SSE or REST API.
Emit new event when a DynamoDB stream receives new events. See the docs here
module.exports = defineComponent({
props: {
pizzly: {
type: "app",
app: "pizzly",
}
},
async run({steps, $}) {
const fetch = require('node-fetch')
const { host, secretKey } = this.pizzly.$auth
const authentication = 'Basic ' + Buffer.from(secretKey + ':').toString('base64')
// Make a test API request to Pizzly. Should return a success message
return await (await fetch(`https://${host}/api/`, { headers: { "Authorization": authentication } })).json()
},
})
You can use the AWS API to build a variety of applications and services. Here
are some examples:
import AWS from 'aws-sdk'
export default defineComponent({
props: {
aws: {
type: "app",
app: "aws",
}
},
async run({steps, $}) {
const { accessKeyId, secretAccessKey } = this.aws.$auth
/* Now, pass the accessKeyId and secretAccessKey to the constructor for your desired service. For example:
const dynamodb = new AWS.DynamoDB({
accessKeyId,
secretAccessKey,
region: 'us-east-1',
})
*/
},
})