1

我已经尝试了比我愿意承认的时间更多的时间来获得一个 openWhisk 函数来调用 Compose.io 上的 postgre sql 数据库。这是我的代码：

我的最新版本是这样的： 

function myAction(params) {
 return new Promise(function(resolve, reject) {
    console.log('Connecting to Compose database');
	// console.log('Params ---> ', params);
    var mysql = require('promise-mysql');
	var fs = require('fs');
	var pg = require('pg');
	var request = require('request')
	var Promise = require('promise/lib/es6-extensions');
	var connString = "postgres:xxxx";
	
	
	
	 pg.connect(connString, function(err, client, done) {
		 console.log("connectiong..", err, client, done);
		 
          if (err) {

            console.log('[connectToCompose] failed to fetch client from pool', err);
            reject(err);

          } else {
            params.client = client; params.done = done;
            console.log('[connectToCompose] obtained a Compose client');
            return(params);

          }
       
		})
		
	//	params.client.done();
	//	console.log("closing connectiong");
 })

}

exports.main = myAction;

我有一个类似的示例，我连接到不同的 SQL 数据库（不是 Compose）并使用 sql promise 而不是 postgre，它可以工作。我究竟做错了什么？

4

1 回答 1

2

要使用 OpenWhisk 和任何数据库产品，您需要使用承诺的 JavaScript 代码；普通nodejs中使用的事件循环不可用。我有一个使用pg-promise的示例（或多或少完全取自项目文档），它对我来说效果很好。尝试这样的事情：

const promise = require('bluebird');

const initOptions = {
    promiseLib: promise // overriding the default (ES6 Promise);
};

const pgp = require('pg-promise')(options);
const conn_info = {...connection info...};

const db = pgp(conn_info);

module.exports.main = function main(args) {
    db.any('SELECT * FROM items')
        .then(data => {
            console.log('DATA:', data);
            // return whatever data you wanted
            resolve({message: 'success'});
        })
        .catch(error => {
            console.log('ERROR:', error);
        });
}

默认情况下，并非所有此处的依赖项都在 OpenWhisk 上可用，因此当您部署操作时，将您的*.js文件和整个文件都包含node_modules/在一个 zip 文件中，然后上传。绝对可以将 Compose Postgres 与 OpenWhisk 一起使用，如果这有助于鼓励您:)

于 2017-08-14T13:32:04.030 回答