This is an API Binding in .Net C# for the new Amazon Selling Partner API.
This library is based on the output of swagger-codegen with the OpenAPI files provided by Amazon (Models) and has been modified by the contributors.
The purpose of this package is to have an easy way of getting started with the Amazon Selling Partner API using C#. You can watch this 📷 YouTube 📣 video to get started quickly.
- AWSSDK.SecurityToken
- AWSSDK.SQS
- Microsoft.CSharp
- System.ComponentModel.Annotations
- System.Reflection
Install-Package CSharpAmazonSpAPI- OrdersV0
- Reports
- FinancesV0
- Feeds Use Case Guide feedType
- ListingsItems Use Case Guide
- Restrictions Use Case Guide
- ProductTypes Use Case Guide
- Uploads Use Case Guide
- shipmentInvoicingV0
- Shippings
- CatalogItemsV0
- CatalogItemsV20220401
- FBAInventory
- FBASmallAndLight
- FBAInboundEligibility
- FulFillmentInbound
- FulFillmentOutbound
- MerchantFulFillment
- Messaging
- Notifications Use Case Guide
- ProductFeesV0
- ProductPricingV0
- Sales
- Sellers
- Services —
getServiceJobByServiceJobId,getServiceJobs,cancelServiceJobByServiceJobId,completeServiceJobByServiceJobId - Solicitations
- Token Use Case Guide
- Authorization
- Easy Ship
- A+ Content
- Replenishment —
listOffers,listOfferMetrics,getSellingPartnerMetrics
- VendorDirectFulfillmentInventoryV1
- VendorDirectFulfillmentOrdersV1
- VendorDirectFulfillmentPaymentsV1
- VendorDirectFulfillmentShippingV1
- VendorDirectFulfillmentTransactionsV1
- VendorOrders
- vendorInvoices
- VendorShipments
- VendorTransactionStatus
To get all the keys you need, follow these steps:
- Create and configure IAM policies and entities
- Register your Application
- Authorize Selling Partner API applications
| Name | Description |
|---|---|
| Marketplace | Marketplace region List of Marketplaces |
| ClientId | Your amazon app id |
| ClientSecret | Your amazon app secret |
| RefreshToken | Check how to get RefreshToken |
For more information about keys, check the Amazon developer documentation. If you are not registered as a developer, please Register to be able to create an application.
- Catalog Items API v0 was removed by Amazon on 2025-03-31.
CatalogItem.ListCatalogItems,CatalogItem.ListCatalogCategories, andCatalogItem.GetCatalogItemJsonare now marked obsolete because the underlying endpoints no longer exist. Use the 2022-04-01 methods (SearchCatalogItems202204,GetCatalogItem202204) instead.- XML feed types (e.g. the legacy inventory feed) were turned off on 2025-07-31. If you previously submitted inventory updates with
_POST_INVENTORY_AVAILABILITY_DATA_or similar XML feed types, migrate toFeedType.JSON_LISTINGS_FEEDwith a JSON-Patch payload (seeFeedsSample.cs).- Orders API v0 will be removed on 2027-03-27. All six v0 operations (
getOrders,getOrder,getOrderBuyerInfo,getOrderAddress,getOrderItems,getOrderItemsBuyerInfo) will start failing on that date. For new code, preferamazonConnection.OrdersV20260101(Orders API v2026-01-01), which collapses those six operations intogetOrderandsearchOrders.Address.Name(Orders v0) is now optional as of Amazon's 2025-10 release. The constructor inAmazonSpApiSDK.Models.Orders.Addressno longer throws whennameis null — handle nullNamedefensively in your code.
You can configure a connection as shown below. See Here for the relevant code file.
AmazonConnection amazonConnection = new AmazonConnection(new AmazonCredential()
{
ClientId = "amzn1.application-XXX-client.XXXXXXXXXXXXXXXXXXXXXXXXXXXX",
ClientSecret = "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX",
RefreshToken= "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX",
MarketPlace = MarketPlace.UnitedArabEmirates, //MarketPlace.GetMarketPlaceByID("A2VIGQ35RCS4UG")
});
or
AmazonConnection amazonConnection = new AmazonConnection(new AmazonCredential()
{
ClientId = "amzn1.application-XXX-client.XXXXXXXXXXXXXXXXXXXXXXXXXXXX",
ClientSecret = "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX",
RefreshToken= "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX",
MarketPlaceID = "A2VIGQ35RCS4UG"
});Please see here for the relevant code file.
The Proxy property accepts any IWebProxy implementation:
AmazonConnection amazonConnection = new AmazonConnection(new AmazonCredential()
{
ClientId = "amzn1.application-XXX-client.XXXXXXXXXXXXXXXXXXXXXXXXXXXX",
ClientSecret = "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX",
RefreshToken= "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX",
MarketPlaceID = "A2VIGQ35RCS4UG",
Proxy = new System.Net.WebProxy("http://xxx.xxx.xxx.xxx:xxxx"),
});For an authenticated proxy, assign any IWebProxy implementation -- for example, a WebProxy with credentials:
AmazonConnection amazonConnection = new AmazonConnection(new AmazonCredential()
{
ClientId = "amzn1.application-XXX-client.XXXXXXXXXXXXXXXXXXXXXXXXXXXX",
ClientSecret = "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX",
RefreshToken= "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX",
MarketPlaceID = "A2VIGQ35RCS4UG",
Proxy = new System.Net.WebProxy("http://xxx.xxx.xxx.xxx:xxxx")
{
Credentials = new System.Net.NetworkCredential("username", "password")
},
});Proxy is not required and will operate normally without it being set.
For more order samples, please check Here.
ParameterOrderList searchOrderList = new ParameterOrderList();
searchOrderList.CreatedAfter = DateTime.UtcNow.AddMinutes(-600000);
searchOrderList.OrderStatuses = new List<OrderStatuses>();
searchOrderList.OrderStatuses.Add(OrderStatuses.Canceled);
var orders = amazonConnection.Orders.GetOrders(searchOrderList);ParameterOrderList searchOrderList = new ParameterOrderList();
searchOrderList.CreatedAfter = DateTime.UtcNow.AddHours(-24);
searchOrderList.OrderStatuses = new List<OrderStatuses>();
searchOrderList.OrderStatuses.Add(OrderStatuses.Unshipped);
searchOrderList.MarketplaceIds = new List<string> { MarketPlace.UnitedArabEmirates.ID };
var orders = amazonConnection.Orders.GetOrders(searchOrderList);var parameterOrderList = new ParameterOrderList
{
CreatedAfter = DateTime.UtcNow.AddHours(-24),
OrderStatuses = new List<OrderStatuses> { OrderStatuses.Unshipped },
MarketplaceIds = new List<string> { MarketPlace.UnitedArabEmirates.ID },
IsNeedRestrictedDataToken = true
};
var orders = _amazonConnection.Orders.GetOrders(parameterOrderList);Order List with parameter including PII data — Advanced (if you want to get specific data elements only)
var parameterOrderList = new ParameterOrderList
{
CreatedAfter = DateTime.UtcNow.AddHours(-24),
OrderStatuses = new List<OrderStatuses> { OrderStatuses.Unshipped },
MarketplaceIds = new List<string> { MarketPlace.UnitedArabEmirates.ID },
IsNeedRestrictedDataToken = true,
RestrictedDataTokenRequest = new CreateRestrictedDataTokenRequest
{
restrictedResources = new List<RestrictedResource>
{
new RestrictedResource
{
method = Method.GET.ToString(),
path = ApiUrls.OrdersApiUrls.Orders,
dataElements = new List<string> { "buyerInfo", "shippingAddress" }
}
}
}
};
var orders = _amazonConnection.Orders.GetOrders(parameterOrderList);AmazonConnection amazonConnection = new AmazonConnection(new AmazonCredential()
{
ClientId = "amzn1.application-XXX-client.XXXXXXXXXXXXXXXXXXXXXXXXXXXX",
ClientSecret = "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX",
RefreshToken= "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX",
Environment=Environments.Sandbox
});
var orders = amazonConnection.Orders.GetOrders
(
new FikaAmazonAPI.Parameter.Order.ParameterOrderList
{
TestCase = Constants.TestCase200
}
);For more report samples, please check Here.
var parameters = new ParameterReportList();
parameters.pageSize = 100;
parameters.reportTypes = new List<ReportTypes>();
parameters.reportTypes.Add(ReportTypes.GET_AFN_INVENTORY_DATA);
parameters.marketplaceIds = new List<string>();
parameters.marketplaceIds.Add(MarketPlace.UnitedArabEmirates.ID);
var reports=amazonConnection.Reports.GetReports(parameters);var parameters = new ParameterCreateReportSpecification();
parameters.reportType = ReportTypes.GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL;
parameters.dataStartTime = DateTime.UtcNow.AddDays(-30);
parameters.dataEndTime = DateTime.UtcNow.AddDays(-10);
parameters.marketplaceIds = new MarketplaceIds();
parameters.marketplaceIds.Add(MarketPlace.UnitedArabEmirates.ID);
parameters.reportOptions = new AmazonSpApiSDK.Models.Reports.ReportOptions();
var report= amazonConnection.Reports.CreateReport(parameters);//use this method automatically know if the report are RDT or not
var data2 = amazonConnection.Reports.CreateReportAndDownloadFile(ReportTypes.GET_EASYSHIP_DOCUMENTS, startDate, null, null);
// OR USE this method to get the document and pass parameter isRestrictedReport = true in case the report will return PII data
var data = amazonConnection.Reports.GetReportDocument("50039018869997",true);An easy way to get the report you need and convert the file returned from Amazon to a class or list. This feature is only available for some reports, as it takes significant effort to cover all report types.
ReportManager reportManager = new ReportManager(amazonConnection);
var products = reportManager.GetProducts(); //GET_MERCHANT_LISTINGS_ALL_DATA
var inventoryAging = reportManager.GetInventoryAging(); //GET_FBA_INVENTORY_AGED_DATA
var ordersByDate = reportManager.GetOrdersByOrderDate(90); //GET_FLAT_FILE_ALL_ORDERS_DATA_BY_ORDER_DATE_GENERAL
var ordersByLastUpdate = reportManager.GetOrdersByLastUpdate(90); //GET_FLAT_FILE_ALL_ORDERS_DATA_BY_LAST_UPDATE_GENERAL
var settlementOrder = reportManager.GetSettlementOrder(90); //GET_V2_SETTLEMENT_REPORT_DATA_FLAT_FILE_V2
var returnMFNOrder = reportManager.GetReturnMFNOrder(90); //GET_FLAT_FILE_RETURNS_DATA_BY_RETURN_DATE
var returnFBAOrder = reportManager.GetReturnFBAOrder(90); //GET_FBA_FULFILLMENT_CUSTOMER_RETURNS_DATA
var reimbursementsOrder = reportManager.GetReimbursementsOrder(180); //GET_FBA_REIMBURSEMENTS_DATA
var feedbacks = reportManager.GetFeedbackFromDays(180); //GET_SELLER_FEEDBACK_DATA
var LedgerDetails = reportManager.GetLedgerDetailAsync(10); //GET_LEDGER_DETAIL_VIEW_DATA
var UnsuppressedInventory = reportManager.GetUnsuppressedInventoryDataAsync().ConfigureAwait(false).GetAwaiter().GetResult(); //GET_FBA_MYI_UNSUPPRESSED_INVENTORY_DATA
var sellerPerformance = reportManager.GetSellerPerformance(); //GET_V2_SELLER_PERFORMANCE_REPORTvar parameters = new ParameterCreateReportSpecification();
parameters.reportType = ReportTypes.GET_MERCHANT_LISTINGS_ALL_DATA;
parameters.marketplaceIds = new MarketplaceIds();
parameters.marketplaceIds.Add(MarketPlace.UnitedArabEmirates.ID);
parameters.reportOptions = new FikaAmazonAPI.AmazonSpApiSDK.Models.Reports.ReportOptions();
var reportId = amazonConnection.Reports.CreateReport(parameters);
var filePath = string.Empty;
string ReportDocumentId = string.Empty;
while (string.IsNullOrEmpty(ReportDocumentId))
{
Thread.Sleep(1000 * 60);
var reportData = amazonConnection.Reports.GetReport(reportId);
if (!string.IsNullOrEmpty(reportData.ReportDocumentId))
{
filePath = amazonConnection.Reports.GetReportFile(reportData.ReportDocumentId);
break;
}
}
//filePath for reportvar data = await amazonConnection.CatalogItem.GetCatalogItem202204Async(
new Parameter.CatalogItems.ParameterGetCatalogItem
{
ASIN = "B00JK2YANC",
includedData = new[] { IncludedData.attributes,
IncludedData.salesRanks,
IncludedData.summaries,
IncludedData.productTypes,
IncludedData.relationships,
IncludedData.dimensions,
IncludedData.identifiers,
IncludedData.images }
});var data = await amazonConnection.CatalogItem.SearchCatalogItems202204Async(
new Parameter.CatalogItems.ParameterSearchCatalogItems202204
{
keywords = new[] { "vitamin c" },
includedData = new[] { IncludedData.attributes,
IncludedData.salesRanks,
IncludedData.summaries,
IncludedData.productTypes,
IncludedData.relationships,
IncludedData.dimensions,
IncludedData.identifiers,
IncludedData.images }
});Product Pricing, For more Pricing sample please check Here.
var data = amazonConnection.ProductPricing.GetPricing(
new Parameter.ProductPricing.ParameterGetPricing()
{
MarketplaceId = MarketPlace.UnitedArabEmirates.ID,
Asins = new string[] { "B00CZC5F0G" }
});var data = amazonConnection.ProductPricing.GetCompetitivePricing(
new Parameter.ProductPricing.ParameterGetCompetitivePricing()
{
MarketplaceId = MarketPlace.UnitedArabEmirates.ID,
Asins = new string[] { "B00CZC5F0G" },
}); var priceDemo = new ProductPricingSample(amazonConnection);
await priceDemo.GetFeaturedOfferExpectedPriceBatch();The 2022-05-01 batch operation returns featured buying options, reference prices, lowest priced offers, and similar items (the similarItems array Amazon added in April 2026) for up to 20 ASIN/marketplace pairs per call. Rate limit is strict — 0.033 req/s, burst 1.
var response = await amazonConnection.ProductPricing.GetCompetitiveSummaryAsync(new CompetitiveSummaryBatchRequest
{
Requests = new List<CompetitiveSummaryRequest>
{
new CompetitiveSummaryRequest
{
Asin = "B00CZC5F0G",
MarketplaceId = MarketPlace.UnitedArabEmirates.ID,
IncludedData = new List<CompetitiveSummaryIncludedData>
{
CompetitiveSummaryIncludedData.similarItems
},
}
}
});
// Read the new similarItems array.
foreach (var r in response.Responses)
foreach (var group in r.Body?.SimilarItems ?? new List<SimilarItems>())
foreach (var item in group.Items)
Console.WriteLine($"Similar ASIN: {item.Asin}");For more notification samples, please check Here.
//EventBridge
var data = amazonConnection.Notification.CreateDestination(
new Notifications.CreateDestinationRequest()
{
Name = "CompanyName",
ResourceSpecification = new Notifications.DestinationResourceSpecification()
{
EventBridge = new Notifications.EventBridgeResourceSpecification("us-east-2", "999999999")
}
});
//SQS
var dataSqs = amazonConnection.Notification.CreateDestination(
new Notifications.CreateDestinationRequest()
{
Name = "CompanyName_AE",
ResourceSpecification = new Notifications.DestinationResourceSpecification
{
Sqs = new Notifications.SqsResource("arn:aws:sqs:us-east-2:9999999999999:NAME")
}
});For more notification samples, please check Here.
//SQS
var result = amazonConnection.Notification.CreateSubscription(
new ParameterCreateSubscription()
{
destinationId = "xxxxxxxxxxxxxxx", // take this from CreateDestination or GetDestinations response
notificationType = NotificationType.ANY_OFFER_CHANGED, // or B2B_ANY_OFFER_CHANGED for B2B prices
payloadVersion = "1.0"
});One subscription per
NotificationType. Amazon doesn't let a single subscription cover multiple notification types — callCreateSubscriptiononce per type. You can reuse the samedestinationId(the same SQS queue) across all of them. To handle LWA secret rotation, add two extra calls pointing at the same destination:// Receive the new secret on rotation. amazonConnection.Notification.CreateSubscription(new ParameterCreateSubscription { notificationType = NotificationType.APPLICATION_OAUTH_CLIENT_NEW_SECRET, destinationId = "xxxxxxxxxxxxxxx", // same destination as your other subscriptions payloadVersion = "1.0", }); // Get advance warning before the current secret expires. amazonConnection.Notification.CreateSubscription(new ParameterCreateSubscription { notificationType = NotificationType.APPLICATION_OAUTH_CLIENT_SECRET_EXPIRY, destinationId = "xxxxxxxxxxxxxxx", payloadVersion = "1.0", });See Application Management — rotate the LWA client secret for the full rotation flow.
Tip: if your subscriptions include
APPLICATION_OAUTH_CLIENT_NEW_SECRET, wrap yourIMessageReceiverwithRotationApplyingMessageReceiverso a rotated client secret is applied toamazonConnection.Credentials.ClientSecretautomatically before your receiver sees the message.
var SQS_URL = Environment.GetEnvironmentVariable("SQS_URL");
var param = new ParameterMessageReceiver(
Environment.GetEnvironmentVariable("AccessKey"),
Environment.GetEnvironmentVariable("SecretKey"),
SQS_URL,
Amazon.RegionEndpoint.USEast2,
WaitTimeSeconds: 20); // Enable SQS long polling to reduce empty receives and cost
var messageReceiver = new CustomMessageReceiver();
// Use CancellationToken for graceful shutdown and wrap in a restart loop
// so the listener recovers from transient errors automatically.
var cts = new CancellationTokenSource();
while (!cts.Token.IsCancellationRequested)
{
try
{
// Static method — no instance needed
await NotificationService.StartReceivingNotificationMessagesAsync(
param, messageReceiver, cancellationToken: cts.Token);
}
catch (OperationCanceledException) when (cts.Token.IsCancellationRequested)
{
break; // Graceful shutdown
}
catch (Exception ex)
{
Console.WriteLine($"Notification listener crashed, restarting in 10s: {ex.Message}");
await Task.Delay(TimeSpan.FromSeconds(10), cts.Token);
}
}
public class CustomMessageReceiver : IMessageReceiver
{
// Track processed notification IDs to handle SQS duplicate delivery
private readonly ConcurrentDictionary<string, byte> _processedNotificationIds = new();
private readonly ConcurrentQueue<string> _idQueue = new();
private const int MaxTrackedIds = 10_000;
public void ErrorCatch(Exception ex)
{
Console.WriteLine($"Notification error: {ex.Message}");
}
public void NewMessageRevicedTriger(NotificationMessageResponce message)
{
// Deduplicate: SQS standard queues may deliver the same message more than once
var notificationId = message?.NotificationMetadata?.NotificationId;
if (notificationId != null && !_processedNotificationIds.TryAdd(notificationId, 0))
return;
// Cap the dedup cache so it doesn't grow forever
if (notificationId != null)
{
_idQueue.Enqueue(notificationId);
while (_idQueue.Count > MaxTrackedIds && _idQueue.TryDequeue(out var oldId))
_processedNotificationIds.TryRemove(oldId, out _);
}
//Your Code here
}
}Complete workflow following the Amazon SQS notification setup guide. Before running this code, grant SP-API permission to write to your SQS queue in the AWS Console.
If you also subscribe to
APPLICATION_OAUTH_CLIENT_NEW_SECREThere, see Notifications — Read Messages for theRotationApplyingMessageReceiverwrapper that auto-applies rotated secrets.
// Step 3: Create a destination (grantless operation — no seller authorization needed)
var destination = amazonConnection.Notification.CreateDestination(
new Notifications.CreateDestinationRequest()
{
Name = "CompanyName_SQS",
ResourceSpecification = new Notifications.DestinationResourceSpecification
{
Sqs = new Notifications.SqsResource("arn:aws:sqs:us-east-2:9999999999999:NAME")
}
});
// Step 4: Create a subscription using the destinationId from Step 3
// processingDirective is optional — only supported for ANY_OFFER_CHANGED and ORDER_CHANGE
var subscription = amazonConnection.Notification.CreateSubscription(
new ParameterCreateSubscription()
{
destinationId = destination.DestinationId,
notificationType = NotificationType.ANY_OFFER_CHANGED,
payloadVersion = "1.0",
processingDirective = new Notifications.ProcessingDirective
{
EventFilter = new Notifications.EventFilter
{
EventFilterType = "ANY_OFFER_CHANGED",
MarketplaceIds = new List<string> { "ATVPDKIKX0DER" },
AggregationSettings = new Notifications.AggregationSettings
{
AggregationTimePeriod = Notifications.AggregationTimePeriod.FiveMinutes
}
}
}
});Here is a full sample for submitting a feed to change price, generate XML, and get the final processing report, same as in the documentation.
Note: Not all feed types are implemented yet. All classes are
partialfor easy extension — you can generate XML outside the library and use it to submit data. Currently supported: submit existing product, change quantity, and change price. Most XSD files are listed inSource\FikaAmazonAPI\ConstructFeed\xsdto help you generate classes for your app.
For more feed samples, please check Here.
ConstructFeedService createDocument = new ConstructFeedService("{SellerID}", "1.02");
var list = new List<PriceMessage>();
list.Add(new PriceMessage()
{
SKU = "8201031206122...",
StandardPrice = new StandardPrice()
{
currency = amazonConnection.GetCurrentMarketplace.CurrencyCode.ToString(),
Value = (201.0522M).ToString("0.00")
}
});
createDocument.AddPriceMessage(list);
var xml = createDocument.GetXML();
var feedID = amazonConnection.Feed.SubmitFeed(xml, FeedType.POST_PRODUCT_PRICING_DATA);
Thread.Sleep(1000*30);
var feedOutput=amazonConnection.Feed.GetFeed(feedID);
var outPut=amazonConnection.Feed.GetFeedDocument(feedOutput.ResultFeedDocumentId);
var reportOutpit = outPut.Url;
var processingReport = amazonConnection.Feed.GetFeedDocumentProcessingReport(outPut.Url);string sellerId = "SellerId";
string sku = "SKU";
decimal price = 19.99m;
string jsonString = $@"
{{
""header"": {{
""sellerId"": ""{sellerId}"",
""version"": ""2.0"",
""issueLocale"": ""en_US""
}},
""messages"": [
{{
""messageId"": 1,
""sku"": ""{sku}"",
""operationType"": ""PATCH"",
""productType"": ""PRODUCT"",
""patches"": [
{{
""op"": ""replace"",
""path"": ""/attributes/purchasable_offer"",
""value"": [
{{
""currency"": ""USD"",
""our_price"": [
{{
""schedule"": [
{{
""value_with_tax"": {price}
}}
]
}}
]
}}
]
}}
]
}}
]
}}";
string feedID = await amazonConnection.Feed.SubmitFeedAsync(jsonString, FeedType.JSON_LISTINGS_FEED, new List<string>() { MarketPlace.UnitedArabEmirates.ID }, null, ContentType.JSON);
Thread.Sleep(1000*60);
var feedOutput = amazonConnection.Feed.GetFeed(feedID);
var outPut = amazonConnection.Feed.GetFeedDocument(feedOutput.ResultFeedDocumentId);
var reportOutpit = outPut.Url;
var processingReport = await amazonConnection.Feed.GetJsonFeedDocumentProcessingReportAsync(output); [HttpGet("AuthorizeAmazon")]
public async Task<IActionResult> AuthorizeAmazon()
{
// Step 2-5 of the website authorization workflow.
// Step 2-3: Amazon calls our log-in URI with amazon_callback_uri.
var amazonCallbackUri = Request.Query["amazon_callback_uri"].ToString();
if (!string.IsNullOrEmpty(amazonCallbackUri))
{
var amazonState = Request.Query["amazon_state"].ToString();
var version = configuration["FikaAmazonAPI:AuthorizeVersion"];
var redirectUri = configuration["FikaAmazonAPI:AmazonCallbackUri"];
var generatedState = Guid.NewGuid().ToString("N");
Response.Cookies.Append("amazon_oauth_state", generatedState, new CookieOptions
{
HttpOnly = true,
Secure = true,
SameSite = SameSiteMode.Lax,
Expires = DateTimeOffset.UtcNow.AddMinutes(5)
});
var query = new Dictionary<string, string?>
{
["redirect_uri"] = redirectUri,
["amazon_state"] = amazonState,
["state"] = generatedState
};
if (!string.IsNullOrEmpty(version))
{
query["version"] = version;
}
Response.Headers["Referrer-Policy"] = "no-referrer";
var redirectUrl = QueryHelpers.AddQueryString(amazonCallbackUri, query!);
return Redirect(redirectUrl);
}
// Step 4-5: Amazon redirects back to our redirect_uri with authorization code.
var state = Request.Query["state"].ToString();
var sellingPartnerId = Request.Query["selling_partner_id"].ToString();
var mwsAuthToken = Request.Query["mws_auth_token"].ToString();
var code = Request.Query["spapi_oauth_code"].ToString();
var storedState = Request.Cookies["amazon_oauth_state"];
if (string.IsNullOrEmpty(state) || storedState != state)
{
return BadRequest("Invalid state");
}
Response.Cookies.Delete("amazon_oauth_state");
if (string.IsNullOrEmpty(code))
{
return BadRequest("Missing spapi_oauth_code");
}
var clientId = configuration["FikaAmazonAPI:ClientId"];
var clientSecret = configuration["FikaAmazonAPI:ClientSecret"];
var callbackUri = configuration["FikaAmazonAPI:AmazonCallbackUri"];
using var httpClient = new HttpClient();
var form = new FormUrlEncodedContent(new Dictionary<string, string>
{
["grant_type"] = "authorization_code",
["code"] = code,
["client_id"] = clientId ?? string.Empty,
["client_secret"] = clientSecret ?? string.Empty,
["redirect_uri"] = callbackUri ?? string.Empty
});
using var response = await httpClient.PostAsync("https://api.amazon.com/auth/o2/token", form);
var responseBody = await response.Content.ReadAsStringAsync();
if (!response.IsSuccessStatusCode)
{
return BadRequest(responseBody);
}
using var document = JsonDocument.Parse(responseBody);
var refreshToken = document.RootElement.GetProperty("refresh_token").GetString();
var accessToken = document.RootElement.GetProperty("access_token").GetString();
return Json(new
{
state,
selling_partner_id = sellingPartnerId,
mws_auth_token = mwsAuthToken,
refresh_token = refreshToken,
access_token = accessToken
});
}ConstructFeedService createDocument = new ConstructFeedService("{SellerID}", "1.02");
var list = new List<InventoryMessage>();
list.Add(new InventoryMessage()
{
SKU = "82010312061.22...",
Quantity = 2,
FulfillmentLatency = "11",
});
createDocument.AddInventoryMessage(list);
var xml = createDocument.GetXML();
var feedID = amazonConnection.Feed.SubmitFeed(xml, FeedType.POST_INVENTORY_AVAILABILITY_DATA);
Thread.Sleep(1000*30);
var feedOutput=amazonConnection.Feed.GetFeed(feedID);
var outPut=amazonConnection.Feed.GetFeedDocument(feedOutput.ResultFeedDocumentId);
var reportOutpit = outPut.Url;
var processingReport = amazonConnection.Feed.GetFeedDocumentProcessingReport(outPut.Url);public void SubmitFeedProductImage()
{
ConstructFeedService createDocument = new ConstructFeedService("A3J37AJU4O9RHK", "1.02");
var list = new List<ProductImageMessage>();
list.Add(new ProductImageMessage()
{
SKU = "8201031206122...",
ImageLocation = "http://xxxx.com/1.jpeg",
ImageType = ImageType.Main
}) ;
createDocument.AddProductImageMessage(list);
var xml = createDocument.GetXML();
var feedID = amazonConnection.Feed.SubmitFeed(xml, FeedType.POST_PRODUCT_IMAGE_DATA);
}ConstructFeedService createDocument = new ConstructFeedService("{sellerId}", "1.02");
var list = new List<OrderFulfillmentMessage>();
list.Add(new OrderFulfillmentMessage()
{
AmazonOrderID = "{orderId}",
FulfillmentDate = DateTime.Now.ToString("yyyy-MM-dd'T'HH:mm:ss.fffK"),
FulfillmentData = new FulfillmentData()
{
CarrierName = "Correos Express",
ShippingMethod = "ePaq",
ShipperTrackingNumber = "{trackingNumber}"
}
});
createDocument.AddOrderFulfillmentMessage(list);
var xml = createDocument.GetXML();
var feedID = amazonConnection.Feed.SubmitFeed(xml, FeedType.POST_ORDER_FULFILLMENT_DATA);public void SubmitFeedOrderAdjustment()
{
ConstructFeedService createDocument = new ConstructFeedService("A3J37AJU4O9RHK", "1.02");
var list = new List<OrderAdjustmentMessage>();
list.Add(new OrderAdjustmentMessage()
{
AmazonOrderID = "AMZ1234567890123",
ActionType = AdjustmentActionType.Refund,
AdjustedItem = new List<AdjustedItem>() {
new AdjustedItem() {
AmazonOrderItemCode = "52986411826454",
AdjustmentReason = AdjustmentReason.CustomerCancel,
DirectPaymentAdjustments = new List<DirectPaymentAdjustments>()
{
new DirectPaymentAdjustments()
{
Component = new List<DirectPaymentAdjustmentsComponent>()
{
new DirectPaymentAdjustmentsComponent() {
DirectPaymentType = "Credit Card Refund",
Amount = new CurrencyAmount() {
Value = 10.50M,
currency = amazonConnection.GetCurrentMarketplace.CurrencyCode
}
}
}
}
}
}
}
});
createDocument.AddOrderAdjustmentMessage(list);
var xml = createDocument.GetXML();
var feedID = amazonConnection.Feed.SubmitFeed(xml, FeedType.POST_PAYMENT_ADJUSTMENT_DATA);
}Please read this doc to get all information about this limitation https://developer-docs.amazon.com/sp-api/docs/usage-plans-and-rate-limits
We calculate the waiting time by reading the x-amzn-RateLimit-Limit header:
int sleepTime = (int)((1 / header["x-amzn-RateLimit-Limit"] ) * 1000);
You can also disable the library's rate limit handling by setting IsActiveLimitRate = false in AmazonCredential:
var amazonConnection = new AmazonConnection(new AmazonCredential()
{
.
.
IsActiveLimitRate=false
});You can enable logging for all HTTP requests and responses by setting IsDebugMode = true in AmazonCredential:
var amazonConnection = new AmazonConnection(new AmazonCredential()
{
.
.
IsDebugMode = true
});var result = amazonConnection.Restrictions.GetListingsRestrictions(
new Parameter.Restrictions.ParameterGetListingsRestrictions
{
asin = "AAAAAAAAAA",
sellerId = "AXXXXXXXXXXXX"
});ShipmentRequestDetails shipmentRequestDetails = new ShipmentRequestDetails()
{
AmazonOrderId = "999-9999-999999",
ItemList = new ItemList()
{
new FikaAmazonAPI.AmazonSpApiSDK.Models.MerchantFulfillment.Item()
{
OrderItemId = "52986411826454",
Quantity = 1
}
},
ShipFromAddress = new Address()
{
AddressLine1 = "300 St",
City = "City",
PostalCode = "48123",
Email = "[mail@yahoo.com](mailto:mail@yahoo.com)",
Phone = "999999999",
StateOrProvinceCode = "MI",
CountryCode = "US",
Name = "FirstName LastName"
},
PackageDimensions = new PackageDimensions()
{
Height = 10,
Width = 10,
Length = 10,
Unit = UnitOfLength.Inches
},
Weight = new Weight()
{
Value = 10,
Unit = UnitOfWeight.Oz
},
ShippingServiceOptions = new ShippingServiceOptions()
{
DeliveryExperience = DeliveryExperienceType.NoTracking,
CarrierWillPickUp = false,
CarrierWillPickUpOption = CarrierWillPickUpOption.ShipperWillDropOff
}
};
var shipmentRequest = new CreateShipmentRequest(
shipmentRequestDetails,
shippingServiceId: "UPS_PTP_2ND_DAY_AIR",
shippingServiceOfferId: "WHgxtyn6qjGGaC");
var shipmentResponse = amazonConnection.MerchantFulfillment.CreateShipment(shipmentRequest);var list = amazonConnection.ProductType.SearchDefinitionsProductTypes(
new Parameter.ProductTypes.SearchDefinitionsProductTypesParameter()
{
keywords = new List<string> { String.Empty },
});var def = amazonConnection.ProductType.GetDefinitionsProductType(
new Parameter.ProductTypes.GetDefinitionsProductTypeParameter()
{
productType = "PRODUCT",
requirements = Requirements.LISTING,
locale = AmazonSpApiSDK.Models.ProductTypes.LocaleEnum.en_US
}); DateTime queryStart = DateTime.UtcNow.AddDays(-11).Date;
DateTime queryEnd = DateTime.UtcNow;
var parameters = new ParameterGetOrderMetrics();
parameters.marketplaceIds = new MarketplaceIds();
parameters.marketplaceIds.Add(MarketPlace.UnitedArabEmirates.ID);
parameters.interval = queryStart.ToString("yyyy-MM-ddTHH:mm:ss", CultureInfo.InvariantCulture) + "Z--" + queryEnd.ToString("yyyy-MM-ddTHH:mm:ss", CultureInfo.InvariantCulture) + "Z";
parameters.granularity = Constants.GranularityEnum.Day;
parameters.firstDayOfWeek = Constants.FirstDayOfWeek.monday;
var sales = amazonConnection.Sales.GetOrderMetrics(parameters);For more samples, see ServicesSample.cs.
var serviceJob = amazonConnection.Services.GetServiceJobByServiceJobId("SJ-1234567890");
// As of Amazon's April 2026 release, the response contains a payments[] array.
var totalPaid = serviceJob.Payments?
.Where(p => p.Amount?.Value != null)
.Sum(p => p.Amount.Value);For more samples, see AplusContentSample.cs. All ten operations share a 10 req/s, burst 10 rate limit; list/search ops auto-page internally.
// 1. List all A+ docs on the account.
var docs = await amazonConnection.AplusContent.SearchContentDocumentsAsync();
// 2. Fetch one with full content + metadata.
var doc = await amazonConnection.AplusContent.GetContentDocumentAsync(
contentReferenceKey: docs.First().ContentReferenceKey,
includedDataSet: new List<AplusIncludedDataType> { AplusIncludedDataType.CONTENTS, AplusIncludedDataType.METADATA });
// 3. Create a minimal doc with one STANDARD_TEXT module.
var created = await amazonConnection.AplusContent.CreateContentDocumentAsync(new PostContentDocumentRequest
{
ContentDocument = new ContentDocument
{
Name = "My new A+ doc",
ContentType = ContentType.EBC,
Locale = "en-US",
ContentModuleList = new List<ContentModule>
{
new ContentModule
{
ContentModuleType = ContentModuleType.STANDARD_TEXT,
StandardText = new StandardTextModule
{
Headline = new TextComponent { Value = "About this product" },
Body = new ParagraphComponent
{
TextList = new List<TextComponent>
{
new TextComponent { Value = "Replace with your product story." }
}
}
}
}
}
}
});
// 4. Link ASINs and submit for approval.
await amazonConnection.AplusContent.PostContentDocumentAsinRelationsAsync(
created.ContentReferenceKey,
new PostContentDocumentAsinRelationsRequest { AsinSet = new List<string> { "B00CZC5F0G" } });
await amazonConnection.AplusContent.PostContentDocumentApprovalSubmissionAsync(created.ContentReferenceKey);ApplicationManagementSample.cs shows the full flow.
The HTTP response carries no useful body — the rotated secret is delivered asynchronously to a developer-registered SQS queue subscribed to the APPLICATION_OAUTH_CLIENT_NEW_SECRET notification. The pattern is:
// 1. One-time setup: subscribe to the rotation notifications.
amazonConnection.Notification.CreateSubscription(new ParameterCreateSubscription
{
notificationType = NotificationType.APPLICATION_OAUTH_CLIENT_NEW_SECRET,
destinationId = yourSqsDestinationId, // pre-existing destination on an SQS queue
payloadVersion = "1.0",
});
// 2. Trigger rotation. Uses LWA grant_type=client_credentials with the rotation scope —
// the SDK handles that special auth path internally.
amazonConnection.ApplicationManagement.RotateApplicationClientSecret();
// 3. Poll your SQS queue. The SDK already deserializes the payload into
// NotificationMessageResponce.Payload.ApplicationOAuthClientNewSecret
// (an ApplicationOAuthClientNewSecretNotification with NewClientSecret +
// NewClientSecretExpiryTime + OldClientSecretExpiryTime).If you already use NotificationService.StartReceivingNotificationMessages* for SQS, wrap your existing receiver in RotationApplyingMessageReceiver to apply rotated secrets automatically — your code keeps doing what it did before, the credential bag updates transparently, and your onRotated callback persists the rotated values to your database so the next process start picks them up.
Persist all four fields:
| Field | What to do with it |
|---|---|
payload.ClientId |
Row key. |
payload.NewClientSecret |
Store encrypted (Key Vault / KMS / encrypted column). |
payload.NewClientSecretExpiryTime |
When this new secret itself expires — schedule the next rotation before this. |
payload.OldClientSecretExpiryTime |
Deadline to finish the cutover. Until this passes, both secrets work; after, only the new one does. |
var wrapped = new RotationApplyingMessageReceiver(
inner: myReceiver,
credentials: amazonConnection.Credentials,
onRotated: payload =>
{
// TODO: save these four values to your database, with NewClientSecret encrypted at rest.
// The SDK has already applied payload.NewClientSecret to amazonConnection.Credentials,
// so a transient DB error here doesn't break the running process — log and continue.
myDb.SaveRotatedSecret(
clientId: payload.ClientId,
newClientSecret: payload.NewClientSecret,
newClientSecretExpiresAt: payload.NewClientSecretExpiryTime,
oldClientSecretExpiresAt: payload.OldClientSecretExpiryTime);
});
NotificationService.StartReceivingNotificationMessages(param, wrapped);A reference IClientSecretStore interface is in ApplicationManagementSample.cs.
To get advance warning before a secret expires, also subscribe to NotificationType.APPLICATION_OAUTH_CLIENT_SECRET_EXPIRY — its payload is ApplicationOAuthClientSecretExpiryNotification with a ClientSecretExpiryTime.
For more samples, see ReplenishmentSample.cs. All three operations are rate-limited to 1 req/s, burst 1.
// 1. Find offers with paused or at-risk deliveries, sorted by inventory ascending.
var atRisk = await amazonConnection.Replenishment.ListOffersAsync(new ListOffersRequest
{
Pagination = new ListOffersRequestPagination { Limit = 100 },
Filters = new ListOffersRequestFilters
{
MarketplaceId = MarketPlace.US.ID,
ProgramTypes = new List<ProgramType> { ProgramType.SUBSCRIBE_AND_SAVE },
DeliveriesConditions = new List<DeliveryConditionType>
{
DeliveryConditionType.NEXT_30_DAYS_DELIVERIES_PAUSED_PRICING,
DeliveryConditionType.NEXT_30_DAYS_DELIVERIES_AT_LOW_INVENTORY_RISK,
},
},
Sort = new ListOffersRequestSort { Order = SortOrder.ASC, Key = ListOffersSortKey.INVENTORY },
});
// 2. Per-offer metrics — now offer-level (SKU + FulfillmentChannelType) per April 2026 release.
var perOffer = await amazonConnection.Replenishment.ListOfferMetricsAsync(new ListOfferMetricsRequest { /*...*/ });
// 3. Seller-level metrics including the new REVENUE_PENETRATION metric.
var spMetrics = await amazonConnection.Replenishment.GetSellingPartnerMetricsAsync(new GetSellingPartnerMetricsRequest
{
AggregationFrequency = AggregationFrequency.MONTH,
TimeInterval = new TimeInterval { StartDate = monthStart, EndDate = monthEnd },
TimePeriodType = TimePeriodType.PERFORMANCE,
MarketplaceId = MarketPlace.US.ID,
ProgramTypes = new List<ProgramType> { ProgramType.SUBSCRIBE_AND_SAVE },
Metrics = new List<Metric> { Metric.REVENUE_PENETRATION, Metric.TOTAL_SUBSCRIPTIONS_REVENUE },
});// Auto-pages through every result page and returns a flat list.
var upcoming = amazonConnection.Services.GetServiceJobs(new ParameterGetServiceJobs
{
scheduleStartDate = DateTime.UtcNow,
scheduleEndDate = DateTime.UtcNow.AddDays(14),
serviceJobStatus = new List<string> { "SCHEDULED", "PENDING_SCHEDULE" },
pageSize = 50,
sortField = "JOB_DATE",
sortOrder = "ASC",
});
// Returns true when the request succeeds with no errors in the response body.
amazonConnection.Services.CancelServiceJobByServiceJobId("SJ-1234567890", "BUYER_REQUESTED_CANCELLATION");
amazonConnection.Services.CompleteServiceJobByServiceJobId("SJ-1234567890");If you have questions, please ask in GitHub discussions
- Improve documentation
- Fork it (https://github.com/abuzuhri/Amazon-SP-API-CSharp/fork)
- Clone it (
git clone https://github.com/{YOUR_USERNAME}/Amazon-SP-API-CSharp) - Create your feature branch (
git checkout -b your_branch_name) - Commit your changes (
git commit -m 'Description of a commit') - Push to the branch (
git push origin your_branch_name) - Create a new Pull Request
If you are looking for a complete Feedback solution, you might want to consider giving Soon.se a shot.
We offer consultation on everything SP-API related. Book your meeting here:
Thanks go out to everybody who worked on this package.