Real Simple Syndication
Emit new event when a new asset is created.
Emit new event for each new activity related to any asset within the platform. Note that event only emitted when it is created by the API or Pipedream DataTrails action: Create new Event.
Allows for the addition of a new asset into the RKVST system. See the documentation
Retrieve multiple RSS feeds and return a merged array of items sorted by date See documentation
Create a new event based on an asset. See the documentation
The RSS app allows users to automatically fetch and parse updates from web feeds. This functionality is pivotal for staying abreast of content changes or updates from websites, blogs, and news outlets that offer RSS feeds. With Pipedream, you can harness the RSS API to trigger workflows that enable a broad range of automations, like content aggregation, monitoring for specific keywords, notifications, and data synchronization across platforms.
module.exports = defineComponent({
props: {
rss: {
type: "app",
app: "rss",
}
},
async run({steps, $}) {
// Retrieve items from a sample feed
const Parser = require('rss-parser');
const parser = new Parser();
const stories = []
// Replace with your feed URL
const url = "https://pipedream.com/community/latest.rss"
const feed = await parser.parseURL(url);
const { title, items } = feed
this.title = title
if (!items.length) {
$end("No new stories")
}
this.items = items
},
})
The DataTrails API, formerly known as RKVST, is designed to track the provenance and integrity of digital assets across their lifecycle. With this API, you can create an immutable record of actions, decisions, and processes that affect any asset, thereby providing an auditable trail. Leveraging Pipedream, you can automate workflows that require secure, verifiable, and traceable asset history. You can react to events in real-time, integrate with other services, and trigger actions based on asset changes or compliance checks.
import { axios } from "@pipedream/platform"
export default defineComponent({
props: {
rkvst: {
type: "app",
app: "rkvst",
}
},
async run({steps, $}) {
return await axios($, {
url: `https://app.datatrails.ai/archivist/v2/assets`,
headers: {
Authorization: `Bearer ${this.rkvst.$auth.oauth_access_token}`,
},
})
},
})