小编Bru*_*ner的帖子

标题几乎解释了它.否则一切正常,我可以使用Dapper从我的应用程序INSERT/ UPDATE/ DELETE/ SELECT没有问题.我遇到的具体问题是在尝试将INSERT值放入我的表格时.

我已经尝试了几种不同的方法,似乎找不到一个能够正确地将JSON值插入到我的PostgreSQL数据库中的方法.我总是得到错误,我试图插入TEXT数据库所需的类型值JSON.

为简洁起见,我将尝试仅包含相关的代码片段.

以下RAW SQL在pgAdmin中运行得非常好:

INSERT INTO public.sales(
     firstname, lastname, middlename, address1, address2, city, state, 
    zipcode, dateofbirth, phonenumber, phonenumberalt, insurancename, insuranceid, binnumber, pcnnumber, groupid, 
    offerid, offercodes, timestamp, otherfields)
    VALUES ('Fname', 'lname1', NULL, '123 ABC St', NULL, 'Washington DC', 'DC', 
            '10062', '1988-01-01', '9545555555', NULL, 'BCBS', 'XYZ123', '600100', 'ABC123', 'DC123', 
            '12', '10,50,12', '2017-03-24', '{     "guid": "9c36adc1-7fb5-4d5b-83b4-90356a46061a",     "name": "Angela Barton",     "is_active": true,     "company": "Magnafone",     "address": "178 Howard …

我正在使用.net sdk将消息推送到SNS，然后SNS将消息发布到订阅的SQS队列，但是SNS添加了元数据，例如消息类型等，并且我最终得到了我不想要的更大的JSON负载，尤其是当SQS受到限制时每条消息 256k。

是否可以向 SNS 发送命令并告诉它不要发送该元数据？

这是代码：

var credentials = new StoredProfileAWSCredentials("dev");

using (var client = new AmazonSimpleNotificationServiceClient(credentials, Amazon.RegionEndpoint.EUWest1))
{
    var request = new PublishRequest();
    request.Message = message;
    request.TargetArn = "ARN";

    var response = client.Publish(request);
    // return response;
}

这是 SNS 推送到 SQS 的内容：

{  
   "Type":"Notification",
   "MessageId":"3333333",
   "TopicArn":"ARN",
   "Message": {
       "Id":45,
       "MessageId":"a871f8d7-7091-4548-87c5-da3bb4131044",
       "Payload": {
           "Internalid":"a7c50558-fc9c-47a6-b0ed-cb0cf5020f55",
           "MessageId":"a871f8d7-7091-4548-87c5-da3bb4131044",
           "TravelersName":"aaa aaaa",
           "TravelersEmail":"aaa@aa.com",
           "OwnersEmail":null,
           "AccommodationId":1,
           "BookingCode":"a523cd07-5506-48ad-9380-2e94002722e0"
       },
       "EventName":"BookingRecordCreated",
       "CreatedOnUtc":"2016-09-26T15:14:55.437",
       "HandledOnUtc":null
    },
    "Timestamp":"2016-09-26T15:14:50.923Z",
    "SignatureVersion":"1",
    "Signature":"dfgdfg///==",
    "SigningCertURL":"https://sns",
    "UnsubscribeURL":"https://sns."
}

这就是我发布到 SNS 的内容

"Message":{
   "Id":45,
   "MessageId":"a871f8d7-7091-4548-87c5-da3bb4131044",
   "Payload": …