Подключите Node.js BOT к базе данных MS Azure SQL - PullRequest
Новая
       12

Подключите Node.js BOT к базе данных MS Azure SQL

0 голосов
/ 03 мая 2018

У меня есть рабочий бот MS Teams, написанный на Node.js. Бот задает ряд вопросов и в настоящее время отображает ответы в конце, получая доступ к переменным сеанса. Все хорошо.

Сейчас я пытаюсь сохранить переменные сеанса в SQL-базе данных MS Azure. БД правильно настроена в Azure, поскольку я могу получать к ней доступ и записывать данные в SSMS. Но я полагаю, что, вероятно, неправильно подключаюсь к БД в своем коде бота. Код бота, который я использую, взят из:

подключение к SQL с использованием Node.js

Этот код имеет смысл для меня. Но как мне использовать этот код в моем боте? Вот что я пытался сделать до сих пор ...

В настоящее время я использую локальную память MemoryBotStorage () и задаю для этого значение. 

var inMemoryStorage = new builder.MemoryBotStorage();
.set('storage', inMemoryStorage)

В другой статье Microsoft , посвященной БД Azure Cosmos, говорится: «4.Укажите, что вы хотите использовать свою пользовательскую базу данных вместо хранилища в памяти». Таким образом, из этого я делаю вывод, что должен добавить свой экземпляр sql db в .set («хранилище», БД идет сюда), но мои попытки не увенчались успехом, и я не уверен, что я даже прав?

Итак, мой вопрос: как мне правильно получить доступ к БД сервера SQL Azure из моего кода бота, и является ли ссылка, которую я указал, даже правильным способом?

Спасибо

Примечание. Этот код пример работал для меня - я смог подключиться и запросить свою базу данных Azure - но это всего лишь код БД и он не учитывает код бота.

РЕДАКТИРОВАТЬ - Код: 

const builder = require('botbuilder');
const builderTeams = require('botbuilder-teams');
const restify = require('restify');

const connector = new builderTeams.TeamsChatConnector(
    {

        appId: "My app ID,
        appPassword: "My App PW",
    }

);

var inMemoryStorage = new builder.MemoryBotStorage();


const bot = new builder.UniversalBot(connector, [
    function (session) {
    session.send("Welcome.");
    builder.Prompts.text(session, "Question1?");
},
function (session, results) {
    session.dialogData.question1 = results.response;
    builder.Prompts.text(session, "Question2?");
},
function (session, results) {
    session.dialogData.Question2 = results.response;
    builder.Prompts.text(session, "Question3?");
},
function (session, results) {
    session.dialogData.Question3 = results.response;

    // Begin DB

    var Connection = require('tedious').Connection;
    var config = {
        userName: 'myusername',
        password: 'mypw',
        server: 'myserver.database.windows.net',
        // If you are on Azure SQL Database, you need these next options.  
        options: { encrypt: true, database: 'mydb' }
    };
    var connection = new Connection(config);
    connection.on('connect', function (err) {
        // If no error, then good to proceed.  
        console.log("Connected");
        executeStatement1();
    });

    var Request = require('tedious').Request
    var TYPES = require('tedious').TYPES;

    function executeStatement1() {
        request = new Request("INSERT my (Username, Question1, Question2, Question3, StatusDate) VALUES (@Username, @Question1, @Question2, @Question3, CURRENT_TIMESTAMP);", function (err) {
            if (err) {
                console.log(err);
            }
        });
        request.addParameter('Username', TYPES.NVarChar, session.userData.userName);
        request.addParameter('Question1', TYPES.NVarChar, session.dialogData.Question1);
        request.addParameter('Question2', TYPES.NVarChar, session.dialogData.Question2);
        request.addParameter('Question3', TYPES.NVarChar, session.dialogData.Question3);
        request.on('row', function (columns) {
            columns.forEach(function (column) {
                if (column.value === null) {
                    console.log('NULL');
                } else {
                    console.log("ID of inserted item is " + column.value);
                }
            });
        });
        connection.execSql(request);

    // End DB


    // Process request and display details
    session.endDialog();
}
]).set('storage', inMemoryStorage)


const server = restify.createServer();
server.post('api/messages', connector.listen());
server.listen(portnumber)

Ошибка при запуске с запуском npm: 

npm start

> simplebot@1.0.0 start C:\Developer\dailyStatus
> node index.js

C:\Developer\dailyStatus\index.js:81
]).set('storage', inMemoryStorage)
^

SyntaxError: Unexpected token ]
at createScript (vm.js:80:10)
at Object.runInThisContext (vm.js:139:10)
at Module._compile (module.js:616:28)
at Object.Module._extensions..js (module.js:663:10)
at Module.load (module.js:565:32)
at tryModuleLoad (module.js:505:12)
at Function.Module._load (module.js:497:3)
at Function.Module.runMain (module.js:693:10)
at startup (bootstrap_node.js:188:16)
at bootstrap_node.js:609:3
npm ERR! code ELIFECYCLE
npm ERR! errno 1
npm ERR! simplebot@1.0.0 start: `node index.js`
npm ERR! Exit status 1
npm ERR!
npm ERR! Failed at the simplebot@1.0.0 start script.
npm ERR! This is probably not a problem with npm. There is likely...    

npm ERR! A complete log of this run can be found in:
npm ERR!     C: etc.

FINAL

Мне удалось заставить это работать с этим учебником . Спасибо также Марку ЛеФлёру.

1 Ответ

0 голосов
/ 03 мая 2018

У вас есть несколько опечаток. Например, вам не хватает закрытия " на appId: 

const connector = new builderTeams.TeamsChatConnector(
    {    
        appId: "My app ID",
        appPassword: "My App PW",
    }

);

Вы также не можете объявить function executeStatement1() {...} функцию в вашей функции IDialogWaterfallStep. Это должно жить вне конструктора и называется из IDialogWaterfallStep.

...