TypeScript aws-sdk.SQS类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› TypeScript›TypeScript教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了TypeScript中aws-sdk.SQS类的典型用法代码示例。如果您正苦于以下问题：TypeScript SQS类的具体用法？TypeScript SQS怎么用？TypeScript SQS使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

在下文中一共展示了SQS类的7个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的TypeScript代码示例。

示例1: execute

    public async execute(callback: Lambda.Callback) {
        var sqsClient = new AWS.SQS();

        var queueUrl = "https://sqs.eu-west-1.amazonaws.com/170643467817/MessageBus_" + this.subscriberId;

        console.log("Queue Url: " + queueUrl);

        var receiveMessageResponse = await this.executeAwsRequestAsync<AWS.SQS.ReceiveMessageResult>((callback) =>
            sqsClient.receiveMessage(
                {
                    QueueUrl: queueUrl,
                    MaxNumberOfMessages: 1,
                    VisibilityTimeout: 10
                },
                callback));

        if (receiveMessageResponse.Messages) {
            receiveMessageResponse.Messages.forEach((value, indexed) => {
                var body = JSON.parse(value.Body);
                var result = {
                    receiptHandle: value.ReceiptHandle,
                    message: body.Message
                };
                console.log(result);
                callback(null, JSON.stringify(result));
            });
        } else {
            console.log("No messages");
            callback(null, null);
        }
    }

开发者ID:queueit，项目名称:Queueit.AWSMessageBus，代码行数:31，代码来源:Receive.ts

示例2:

 var receiveMessageResponse = await this.executeAwsRequestAsync<AWS.SQS.ReceiveMessageResult>((callback) =>
     sqsClient.receiveMessage(
         {
             QueueUrl: queueUrl,
             MaxNumberOfMessages: 1,
             VisibilityTimeout: 10
         },
         callback));

开发者ID:queueit，项目名称:Queueit.AWSMessageBus，代码行数:8，代码来源:Receive.ts

示例3:

 var queueAttributesResponse = await this.executeAwsRequestAsync<AWS.SQS.GetQueueAttributesResult>((callback) => {
     sqsClient.getQueueAttributes(
         {
             QueueUrl: createQueueResponse.QueueUrl,
             AttributeNames: ["All"]
         },
         callback);
     });

开发者ID:queueit，项目名称:Queueit.AWSMessageBus，代码行数:8，代码来源:subscribe.ts

示例4: execute

    public async execute(callback: Lambda.Callback) {
        var snsClient = new AWS.SNS();
        var sqsClient = new AWS.SQS();

        var queueName = "MessageBus_" + this.subscriberId;
        var topicName = "MessageBus_" + this.messageType;

        console.log("Queue name: " + queueName);
        console.log("Topic name: " + topicName);

        var createQueueResponse = await this.executeAwsRequestAsync<AWS.SQS.CreateQueueResult>((callback) =>
            sqsClient.createQueue(
                {
                    QueueName: queueName,
                    Attributes: {
                        Policy: '{"Version": "2012-10-17","Id": "SNSSenMessage","Statement": [{"Sid": "Allow-SNS-SendMessage","Effect": "Allow","Principal": "*","Action": ["sqs:SendMessage","SQS:ReceiveMessage","SQS:DeleteMessage"],"Resource": "arn:aws:*:*:*"}]}'
                } },
                callback));
        var queueAttributesResponse = await this.executeAwsRequestAsync<AWS.SQS.GetQueueAttributesResult>((callback) => {
            sqsClient.getQueueAttributes(
                {
                    QueueUrl: createQueueResponse.QueueUrl,
                    AttributeNames: ["All"]
                },
                callback);
            });

        var queueArn = queueAttributesResponse.Attributes["QueueArn"];

        console.log("SQS queue created: " + createQueueResponse.QueueUrl + ":" + queueArn);

        var createTopicResponse = await this.executeAwsRequestAsync<AWS.SNS.CreateTopicResult>((callback) =>
            snsClient.createTopic(
                { Name: topicName },
                callback));

        console.log("SNS topoc created: " + createTopicResponse.TopicArn);

        var subscribeResponse = await this.executeAwsRequestAsync<AWS.SNS.SubscribeResult>((callback) =>
            snsClient.subscribe(
            {
                TopicArn: createTopicResponse.TopicArn,
                Protocol: "sqs",
                Endpoint: queueArn
            },
            callback));

        console.log("SQS queue subscribed to topic: " + subscribeResponse.SubscriptionArn);
    }

开发者ID:queueit，项目名称:Queueit.AWSMessageBus，代码行数:49，代码来源:subscribe.ts

示例5: execute

    public async execute(callback: Lambda.Callback) {
        var sqsClient = new AWS.SQS();

        var queueUrl = "https://sqs.eu-west-1.amazonaws.com/170643467817/MessageBus_" + this.subscriberId;

        console.log("Queue Url: " + queueUrl);
        console.log("Receipt Handle: " + this.receiptHandle);

        await this.executeAwsRequestAsync((callback) =>
            sqsClient.deleteMessage(
                {
                    QueueUrl: queueUrl,
                    ReceiptHandle: this.receiptHandle
                },
                callback));
    }

开发者ID:queueit，项目名称:Queueit.AWSMessageBus，代码行数:16，代码来源:Delete.ts

示例6:

///<reference path="../output/typings/index.d.ts" />

import * as AWS from 'aws-sdk';

var str: string;

var creds: AWS.Credentials;

creds = new AWS.Credentials(str, str);
creds = new AWS.Credentials(str, str, str);
str = creds.accessKeyId;

/*
 * Base service class
 */
var service = new AWS.SQS();
service.makeRequest('POST', {param1:'foobar'}, (err, data) => {});
service.makeUnauthenticatedRequest('POST', {param1:'foobar'}, (err, data) => {});
service.setupRequestListeners();
service.makeRequest('state', {param1:'foobar'}, (err, data) => {});

var endpoint:AWS.Endpoint = service.endpoint;
endpoint.host.toUpperCase() + endpoint.hostname.toUpperCase() + endpoint.href.toUpperCase() + endpoint.port.toFixed() + endpoint.protocol.toUpperCase();

/*
 * Request class
 */

var request = new AWS.Request(service, 'POST', {param1: 'foobar'});
request.send();
request.send((err, data) => null);

开发者ID:Bnaya，项目名称:aws-sdk-typescript，代码行数:31，代码来源:aws-sdk-tests.ts

示例7:

 await this.executeAwsRequestAsync((callback) =>
     sqsClient.deleteMessage(
         {
             QueueUrl: queueUrl,
             ReceiptHandle: this.receiptHandle
         },
         callback));

开发者ID:queueit，项目名称:Queueit.AWSMessageBus，代码行数:7，代码来源:Delete.ts

注：本文中的aws-sdk.SQS类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。