Automated data cleansing for Russian postal addresses, phones and customer names
Emit new event when you add or modify a new row in a table. See the docs here
Emit new event when new rows are returned from a custom query. See the docs here
Emit new event when a new table is added to a database. See the docs here
Using the DaData.ru API, you can build a variety of applications and
integrations that make use of the data the API provides. Here are some
examples:
import { axios } from "@pipedream/platform"
export default defineComponent({
props: {
dadata_ru: {
type: "app",
app: "dadata_ru",
}
},
async run({steps, $}) {
const data = {
"query": `pipedream @`,
}
return await axios($, {
url: `https://suggestions.dadata.ru/suggestions/api/4_1/rs/suggest/email`,
headers: {
"Authorization": `Token ${this.dadata_ru.$auth.api_key}`,
},
data,
})
},
})
MySQL is a powerful database management system used by some of the largest
organizations in the world, including Facebook, Google, and Amazon. MySQL is an
open-source relational database management system (RDBMS), as well as a popular
choice for web applications used by millions of websites.
Some applications that can be built using the MySQL API include:
import mysql from 'mysql2/promise';
export default defineComponent({
props: {
mysql: {
type: "app",
app: "mysql",
}
},
async run({steps, $}) {
const {
host,
port,
username: user,
password,
database,
ca,
key,
cert,
reject_unauthorized: rejectUnauthorized,
} = this.mysql.$auth;
const isRejectUnauthorizedUndefined = rejectUnauthorized === undefined;
const isSslSet = !!(ca && key && cert);
const connectionConfig = {
host,
port,
user,
password,
database,
...(isSslSet && {
ssl: {
rejectUnauthorized: true,
ca,
cert,
key,
},
}),
...(!isSslSet && !isRejectUnauthorizedUndefined && {
ssl: {
rejectUnauthorized,
},
}),
};
const connection = await mysql.createConnection(connectionConfig);
const [rows] = await connection.execute('SELECT NOW()');
return rows;
},
});