mirror of
https://github.com/zhigang1992/DefinitelyTyped.git
synced 2026-05-22 03:37:53 +08:00
256 lines
6.8 KiB
TypeScript
256 lines
6.8 KiB
TypeScript
/// <reference path="aws-sdk.d.ts" />
|
|
|
|
import AWS = require('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;
|
|
|
|
|
|
/*
|
|
* SQS
|
|
*/
|
|
var sqs:AWS.SQS
|
|
|
|
//Default constructor
|
|
sqs = new AWS.SQS();
|
|
|
|
//Locking the API Version
|
|
sqs = new AWS.SQS({apiVersion: '2012-11-05'});
|
|
|
|
// Locking the API Version Globally
|
|
AWS.config.apiVersions = {
|
|
sqs: '2012-11-05',
|
|
// other service API versions
|
|
};
|
|
|
|
sqs.addPermission({
|
|
AWSAccountIds: [ /* required */
|
|
'STRING_VALUE',
|
|
/* more items */
|
|
],
|
|
Actions: [ /* required */
|
|
'STRING_VALUE',
|
|
/* more items */
|
|
],
|
|
Label: 'STRING_VALUE', /* required */
|
|
QueueUrl: 'STRING_VALUE' /* required */
|
|
},
|
|
function(err, data) {
|
|
if (err) console.log(err, err.stack); // an error occurred
|
|
else console.log(data); // successful response
|
|
});
|
|
|
|
sqs.changeMessageVisibility({
|
|
QueueUrl: 'STRING_VALUE', /* required */
|
|
ReceiptHandle: 'STRING_VALUE', /* required */
|
|
VisibilityTimeout: 0 /* required */
|
|
},
|
|
function(err, data) {
|
|
if (err) console.log(err, err.stack); // an error occurred
|
|
else console.log(data); // successful response
|
|
});
|
|
|
|
sqs.changeMessageVisibilityBatch({
|
|
Entries: [ /* required */
|
|
{
|
|
Id: 'STRING_VALUE', /* required */
|
|
ReceiptHandle: 'STRING_VALUE', /* required */
|
|
VisibilityTimeout: 0
|
|
},
|
|
/* more items */
|
|
],
|
|
QueueUrl: 'STRING_VALUE' /* required */
|
|
},
|
|
function(err, data) {
|
|
if (err) console.log(err, err.stack); // an error occurred
|
|
else console.log(data); // successful response
|
|
});
|
|
|
|
sqs.createQueue({
|
|
QueueName: 'STRING_VALUE', /* required */
|
|
Attributes: {
|
|
someKey: 'STRING_VALUE',
|
|
/* anotherKey: ... */
|
|
}
|
|
},
|
|
function(err, data) {
|
|
if (err) console.log(err, err.stack); // an error occurred
|
|
else console.log(data); // successful response
|
|
});
|
|
|
|
sqs.deleteMessage({
|
|
QueueUrl: 'STRING_VALUE', /* required */
|
|
ReceiptHandle: 'STRING_VALUE' /* required */
|
|
},
|
|
function(err, data) {
|
|
if (err) console.log(err, err.stack); // an error occurred
|
|
else console.log(data); // successful response
|
|
});
|
|
|
|
sqs.deleteMessageBatch({
|
|
Entries: [ /* required */
|
|
{
|
|
Id: 'STRING_VALUE', /* required */
|
|
ReceiptHandle: 'STRING_VALUE' /* required */
|
|
},
|
|
/* more items */
|
|
],
|
|
QueueUrl: 'STRING_VALUE' /* required */
|
|
},
|
|
function(err, data) {
|
|
if (err) console.log(err, err.stack); // an error occurred
|
|
else console.log(data); // successful response
|
|
});
|
|
|
|
sqs.deleteQueue({
|
|
QueueUrl: 'STRING_VALUE' /* required */
|
|
},
|
|
function(err, data) {
|
|
if (err) console.log(err, err.stack); // an error occurred
|
|
else console.log(data); // successful response
|
|
});
|
|
|
|
sqs.getQueueAttributes({
|
|
QueueUrl: 'STRING_VALUE', /* required */
|
|
AttributeNames: [
|
|
'Policy | VisibilityTimeout | MaximumMessageSize | MessageRetentionPeriod | ApproximateNumberOfMessages | ApproximateNumberOfMessagesNotVisible | CreatedTimestamp | LastModifiedTimestamp | QueueArn | ApproximateNumberOfMessagesDelayed | DelaySeconds | ReceiveMessageWaitTimeSeconds | RedrivePolicy',
|
|
/* more items */
|
|
]
|
|
},
|
|
function(err, data) {
|
|
if (err) console.log(err, err.stack); // an error occurred
|
|
else console.log(data); // successful response
|
|
});
|
|
|
|
sqs.getQueueUrl({
|
|
QueueName: 'STRING_VALUE', /* required */
|
|
QueueOwnerAWSAccountId: 'STRING_VALUE'
|
|
},
|
|
function(err, data) {
|
|
if (err) console.log(err, err.stack); // an error occurred
|
|
else console.log(data); // successful response
|
|
});
|
|
|
|
sqs.listDeadLetterSourceQueues({
|
|
QueueUrl: 'STRING_VALUE' /* required */
|
|
}, function(err, data) {
|
|
if (err) console.log(err, err.stack); // an error occurred
|
|
else console.log(data); // successful response
|
|
});
|
|
|
|
sqs.listQueues({
|
|
QueueNamePrefix: 'STRING_VALUE'
|
|
},
|
|
function(err, data) {
|
|
if (err) console.log(err, err.stack); // an error occurred
|
|
else console.log(data); // successful response
|
|
});
|
|
|
|
sqs.purgeQueue({
|
|
QueueUrl: 'STRING_VALUE' /* required */
|
|
}, function(err, data) {
|
|
if (err) console.log(err, err.stack); // an error occurred
|
|
else console.log(data); // successful response
|
|
});
|
|
|
|
sqs.receiveMessage({
|
|
QueueUrl: 'STRING_VALUE', /* required */
|
|
AttributeNames: [
|
|
'Policy | VisibilityTimeout | MaximumMessageSize | MessageRetentionPeriod | ApproximateNumberOfMessages | ApproximateNumberOfMessagesNotVisible | CreatedTimestamp | LastModifiedTimestamp | QueueArn | ApproximateNumberOfMessagesDelayed | DelaySeconds | ReceiveMessageWaitTimeSeconds | RedrivePolicy',
|
|
/* more items */
|
|
],
|
|
MaxNumberOfMessages: 0,
|
|
MessageAttributeNames: [
|
|
'STRING_VALUE',
|
|
/* more items */
|
|
],
|
|
VisibilityTimeout: 0,
|
|
WaitTimeSeconds: 0
|
|
}, function(err, data) {
|
|
if (err) console.log(err, err.stack); // an error occurred
|
|
else console.log(data); // successful response
|
|
});
|
|
|
|
sqs.removePermission({
|
|
Label: 'STRING_VALUE', /* required */
|
|
QueueUrl: 'STRING_VALUE' /* required */
|
|
}, function(err, data) {
|
|
if (err) console.log(err, err.stack); // an error occurred
|
|
else console.log(data); // successful response
|
|
});
|
|
|
|
sqs.sendMessage({
|
|
MessageBody: 'STRING_VALUE', /* required */
|
|
QueueUrl: 'STRING_VALUE', /* required */
|
|
DelaySeconds: 0,
|
|
MessageAttributes: {
|
|
someKey: {
|
|
DataType: 'STRING_VALUE', /* required */
|
|
BinaryListValues: [
|
|
new Buffer('...') || 'STRING_VALUE',
|
|
/* more items */
|
|
],
|
|
BinaryValue: new Buffer('...') || 'STRING_VALUE',
|
|
StringListValues: [
|
|
'STRING_VALUE',
|
|
/* more items */
|
|
],
|
|
StringValue: 'STRING_VALUE'
|
|
},
|
|
/* anotherKey: ... */
|
|
}
|
|
},
|
|
function(err, data) {
|
|
if (err) console.log(err, err.stack); // an error occurred
|
|
else console.log(data); // successful response
|
|
});
|
|
|
|
sqs.sendMessageBatch({
|
|
Entries: [ /* required */
|
|
{
|
|
Id: 'STRING_VALUE', /* required */
|
|
MessageBody: 'STRING_VALUE', /* required */
|
|
DelaySeconds: 0,
|
|
MessageAttributes: {
|
|
someKey: {
|
|
DataType: 'STRING_VALUE', /* required */
|
|
BinaryListValues: [
|
|
new Buffer('...') ,
|
|
/* more items */
|
|
],
|
|
BinaryValue: new Buffer('...'),
|
|
StringListValues: [
|
|
'STRING_VALUE',
|
|
/* more items */
|
|
],
|
|
StringValue: 'STRING_VALUE'
|
|
},
|
|
/* anotherKey: ... */
|
|
}
|
|
},
|
|
/* more items */
|
|
],
|
|
QueueUrl: 'STRING_VALUE' /* required */
|
|
},
|
|
function(err, data) {
|
|
if (err) console.log(err, err.stack); // an error occurred
|
|
else console.log(data); // successful response
|
|
});
|
|
|
|
sqs.setQueueAttributes({
|
|
Attributes: { /* required */
|
|
someKey: 'STRING_VALUE',
|
|
/* anotherKey: ... */
|
|
},
|
|
QueueUrl: 'STRING_VALUE' /* required */
|
|
}, function(err, data) {
|
|
if (err) console.log(err, err.stack); // an error occurred
|
|
else console.log(data); // successful response
|
|
});
|
|
|
|
|