How to use dynamoose - 10 common examples
To help you get started, we’ve selected a few dynamoose examples, based on popular ways it is used in public projects.
Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
dynamoosejs / dynamoose / manual_test / index.js View on Github 
const sdk = dynamoose.aws.sdk; // require("aws-sdk");
sdk.config.update({
"accessKeyId": "AKID",
"secretAccessKey": "SECRET",
"region": "us-east-1"
});
const ddb = new dynamoose.aws.sdk.DynamoDB({"endpoint": "http://localhost:8000"});
dynamoose.aws.ddb.set(ddb);
dynamooseOld.setDDB(ddb);
const Cat = dynamooseOld.model("Cat200", {"id": Number, "name": String, "breed": String}, {"create": false});
const CatB = new dynamoose.model("Cat200", {"id": Number, "name": String, "breed": String}, {"create": false});
async function main() {
// const cat = new Cat({"id": 10, "other": "Test", "name": "test"});
// console.log(cat);
// const other = await cat.save();
// console.log(other);
// console.log(await Cat.get(10));
// for (let i = 0; i < 1000; i++) {
// const cat = new CatB({"id": i, "name": new Array(50000).fill("a").join("")});
// await cat.save();
// }
// console.log((await CatB.scan({breed: {contains: 'Terrier'}}).exec()));
// console.log(await Cat.scan({breed: {contains: 'Terrier'}}).exec());// kitty.save().then((res) => console.log(typeof res)).catch((err) => console.error(err));
// kittyB.save().then((res) => console.log(typeof res)).catch((err) => console.error(err));
const sdk = dynamoose.aws.sdk; // require("aws-sdk");
sdk.config.update({
"accessKeyId": "AKID",
"secretAccessKey": "SECRET",
"region": "us-east-1"
});
const ddb = new dynamoose.aws.sdk.DynamoDB({"endpoint": "http://localhost:8000"});
dynamoose.aws.ddb.set(ddb);
dynamooseOld.setDDB(ddb);
const Cat = dynamooseOld.model("Cat200", {"id": Number, "name": String, "breed": String}, {"create": false});
const CatB = new dynamoose.model("Cat200", {"id": Number, "name": String, "breed": String}, {"create": false});
async function main() {
// const cat = new Cat({"id": 10, "other": "Test", "name": "test"});
// console.log(cat);
// const other = await cat.save();
// console.log(other);
// console.log(await Cat.get(10));
// for (let i = 0; i < 1000; i++) {
// const cat = new CatB({"id": i, "name": new Array(50000).fill("a").join("")});
// await cat.save();
// }UserSchema.statics.upsertCognitoUser = function(email, fullName, password, cb) {
var UserModel = dynamoose.model('User', UserSchema, {create: true, waitForActive: true});
var attributeList = [];
attributeList.push(new AmazonCognitoIdentity.CognitoUserAttribute({Name:"email",Value:email}));
attributeList.push(new AmazonCognitoIdentity.CognitoUserAttribute({Name:"name",Value:fullName}));
userPool.signUp(email, password, attributeList, null, function(err, result){
if (err) {
console.log("Error with userPool.signUp");
console.log(err);
return cb(err, result);
}
// console.dir(result);
var cognitoUser = result.user;
console.log('user id ' + result.userSub);
var newUser = new UserModel({
fullName: fullName,UserSchema.statics.upsertFbUser = function(accessToken, refreshToken, profile, cb) {
var UserModel = dynamoose.model('User', UserSchema, {create: true, waitForActive: true});
UserModel.queryOne('email').eq(profile.emails[0].value).exec(
function(err, user) {
if (!user) {
// no user was found, lets create a new one
console.log("No existing user was found with email " + profile.emails[0].value)
var newUser = new UserModel({
fullName: profile.displayName,
email: profile.emails[0].value,
facebookProvider: {
id: profile.id,
token: accessToken
}
});
newUser.create(function(error, savedUser) {
if (error) {const router = require("express").Router();
const dynamoose = require('dynamoose');
const _ = require('lodash');
dynamoose.AWS.config.region = process.env.AWS_REGION;
const Todo = dynamoose.model('Todo', {
userId: {
type: String,
hashKey: true
},
createdAt: {
type: String,
rangeKey: true
},
updatedAt: String,
title: String,
content: String
}, {
create: false, // Create a table if not exist,
});
router.get("/", (req, res, next) => {const got = require('got');
const cheerio = require('cheerio');
const dynamoose = require('dynamoose');
require('aws-sdk').config.region = "ap-northeast-2";
const PortalKeyword = dynamoose.model('PortalKeyword', {
portal: {
type: String,
hashKey: true
},
createdAt: {
type: String,
rangeKey: true
},
keywords: {
type: Array
}
}, {
create: false, // Create a table if not exist,
});
exports.crawler = async function (event, context, callback) {const express = require('express');
const next = require('next');
const path = require('path');
const dynamoose = require('dynamoose');
if (process.env.NODE_ENV === 'development') {
require('dotenv').config({ path: path.resolve(__dirname, `./env/${process.env.ENV_FILE}`) });
}
// Configure Dynamoose
// The accessKeyId & secretAccessKey can be made avaialble via the IAMRole
dynamoose.AWS.config.update({
region: process.env.SERVICE_AWS_REGION,
});
if (process.env.NODE_ENV === 'development') {
/*
For development environment, atleast with dynamoose library,
you need to pass mock access key & secret.
*/
dynamoose.AWS.config.update({
accessKeyId: process.env.AWS_ACCESS_KEY,
secretAccessKey: process.env.AWS_ACCESS_SECRET,
region: process.env.SERVICE_AWS_REGION,
});
dynamoose.local('http://localhost:8000');
}const CognitoUserPool = AmazonCognitoIdentity.CognitoUserPool;
const AWS = require('aws-sdk');
const request = require('request');
const jwkToPem = require('jwk-to-pem');
const jwt = require('jsonwebtoken');
// The amazon-cognito-identity-js uses fetch, which isn't in node.js core
global.fetch = require('node-fetch');
const poolData = {
UserPoolId: config.cognito.userPoolId,
ClientId : config.cognito.appClientId
};
const userPool = new AmazonCognitoIdentity.CognitoUserPool(poolData);
dynamoose.AWS.config.update({
accessKeyId: config.aws.accessKeyId,
secretAccessKey: config.aws.secretAccessKey,
region: config.aws.region
});
// dynamoose.local("http://localhost:8000") // This will set the server to "http://localhost:1234"
module.exports = function () {
var UserSchema = new Schema({
email: {
type: String,
hashKey: true,
required: true,
trim: true,
lowercase: true,
match: /^\w+([\.-]?\w+)*@\w+([\.-]?\w+)*(\.\w{2,3})+$/const router = require("express").Router();
const dynamoose = require('dynamoose');
const _ = require('lodash');
dynamoose.AWS.config.region = process.env.AWS_REGION;
const Todo = dynamoose.model('Todo', {
userId: {
type: String,
hashKey: true
},
createdAt: {
type: String,
rangeKey: true
},
updatedAt: String,
title: String,
content: String
}, {
create: false, // Create a table if not exist,
});require('dotenv').config({ path: path.resolve(__dirname, `./env/${process.env.ENV_FILE}`) });
}
// Configure Dynamoose
// The accessKeyId & secretAccessKey can be made avaialble via the IAMRole
dynamoose.AWS.config.update({
region: process.env.SERVICE_AWS_REGION,
});
if (process.env.NODE_ENV === 'development') {
/*
For development environment, atleast with dynamoose library,
you need to pass mock access key & secret.
*/
dynamoose.AWS.config.update({
accessKeyId: process.env.AWS_ACCESS_KEY,
secretAccessKey: process.env.AWS_ACCESS_SECRET,
region: process.env.SERVICE_AWS_REGION,
});
dynamoose.local('http://localhost:8000');
}
const port = parseInt(process.env.PORT, 10) || 3000;
const dev = process.env.NODE_ENV !== 'production';
const app = next({ dev });
const handle = app.getRequestHandler();
const Dog = require('./models/Dog');
function createServer() {
const server = express();dynamoose
Dynamoose is a modeling tool for Amazon's DynamoDB (inspired by Mongoose)
