Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- using System;
- using System.Collections.Generic;
- using System.Configuration;
- using System.IO;
- using System.Linq;
- using System.Text;
- using Newtonsoft.Json;
- using Amazon;
- using Amazon.EC2;
- using Amazon.EC2.Model;
- using Amazon.Kinesis;
- using Amazon.Kinesis.Model;
- using Amazon.SimpleDB;
- using Amazon.SimpleDB.Model;
- using Amazon.S3;
- using Amazon.S3.Model;
- namespace AwsConsoleApp1
- {
- class Program
- {
- public static void Main(string[] args)
- {
- string input;
- Console.WriteLine("Type a value to be sent to the cloud");
- input = Console.ReadLine();
- Console.Write(GetServiceOutput(input));
- Console.Read();
- }
- public static string GetServiceOutput(string input)
- {
- string output;
- string text = input;
- byte[] oByte = Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(text));
- using (MemoryStream ms = new MemoryStream(oByte))
- {
- //create config that points to AWS region
- AmazonKinesisConfig config = new AmazonKinesisConfig();
- config.RegionEndpoint = Amazon.RegionEndpoint.USEast1;
- //create client that pulls creds from web.config and takes in Kinesis config
- AmazonKinesisClient client = new AmazonKinesisClient(config);
- //create put request
- PutRecordRequest requestRecord = new PutRecordRequest();
- //list name of Kinesis stream
- requestRecord.StreamName = "TestStream";
- //give partition key that is used to place record in particular shard
- requestRecord.PartitionKey = "testkey";
- //add record as memorystream
- requestRecord.Data = ms;
- //PUT the record to Kinesis
- PutRecordResponse responseRecord = client.PutRecord(requestRecord);
- //show shard ID and sequence number to user
- output = "Shard ID: " + responseRecord.ShardId;
- output = output + "Sequence #:" + responseRecord.SequenceNumber;
- return output;
- }
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement