with HUB Planner and RabbitMQ?
The HUB Planner API is a toolset for managing resources, projects, and bookings in a visual and interactive way. By using the API with Pipedream, you can automate complex workflows, sync data across multiple platforms, and create custom integrations to streamline operations. From scheduling resources to analyzing project data, the opportunities are vast for enhancing project management efficiency.
import { axios } from "@pipedream/platform"
export default defineComponent({
props: {
hub_planner: {
type: "app",
app: "hub_planner",
}
},
async run({steps, $}) {
return await axios($, {
url: `https://api.hubplanner.com/v1/project`,
headers: {
"Authorization": `${this.hub_planner.$auth.api_key}`,
"Accept": `application/json`,
"Content-Type": `application/json`,
},
})
},
})
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;
},
})