with RabbitMQ and Axesso Data Service - Amazon?
Requests product detail information using Axesso Data Service. See the documentation
Lists reviews for an Amazon product using Axesso Data Service. See the documentation
Search Amazon products by keyword using Axesso Data Service. See the documentation
import amqp from "amqplib";
export default defineComponent({
props: {
rabbitmq: {
type: "app",
app: "rabbitmq",
}
},
async run({ steps, $ }) {
const url = `amqp://${this.rabbitmq.$auth.username}:${this.rabbitmq.$auth.password}@${this.rabbitmq.$auth.host}:${this.rabbitmq.$auth.port}`;
const connection = await amqp.connect(url);
const channel = await connection.createChannel();
const queue = 'Sample Queue';
await channel.assertQueue(queue, { durable: true });
const message = 'Welcome RabbitMQ + Pipedream users! ' + new Date().toISOString()
channel.sendToQueue(queue, Buffer.from(message), { persistent: true });
console.log(`Sent: ${message}`);
const queueInfo = await channel.checkQueue(queue);
return queueInfo;
},
})
The Axesso Data Service - Amazon API lets you tap into a wealth of data from Amazon, including product searches, price trends, and reviews. In Pipedream, you can harness this data to drive insights, track products, and create custom notifications or reports. Pipedream’s serverless platform simplifies the process of setting up automated workflows that use the Axesso API to respond to events and perform actions in other apps.
import { axios } from "@pipedream/platform"
export default defineComponent({
props: {
axesso_data_service: {
type: "app",
app: "axesso_data_service",
}
},
async run({steps, $}) {
return await axios($, {
url: `https://api.axesso.de/amz/amazon-lookup-product`,
headers: {
"axesso-api-key": `${this.axesso_data_service.$auth.api_key}`,
},
params: {
url: `https://www.amazon.com/dp/B09938DVH2`,
},
})
},
})