Page MenuHomePhabricator
Differential D3233

services: Use .env file for docker-compose
ClosedPublic
Actions

Authored by • jim on Feb 16 2022, 12:09 PM.
Tags
None
Referenced Files
F6239059: D3233.diff
Thu, Apr 24, 7:23 PM
F6216700: D3233.id9940.diff
Thu, Apr 24, 3:49 AM
Unknown Object (File)
Thu, Apr 17, 2:21 PM
Unknown Object (File)
Thu, Apr 17, 8:57 AM
Unknown Object (File)
Wed, Apr 16, 9:19 PM
Unknown Object (File)
Wed, Apr 16, 2:10 PM
Unknown Object (File)
Tue, Apr 8, 11:18 PM
Unknown Object (File)
Tue, Apr 8, 6:57 AM
View All Files
Subscribers
• adrian
atul
• benschac
tomek

Details

Reviewers
• karol
ashoat
• max
varun
Commits
rCOMM90ddba6307b1: services: Use .env file for docker-compose
Summary

This replaces the services_config.sh script.

https://linear.app/comm/issue/ENG-778/use-docker-compose-environment-file

Test Plan

Run launch scripts

Diff Detail

Repository
rCOMM Comm
Lint
No Lint Coverage
Unit
No Test Coverage

Event Timeline

• jim created this revision.Feb 16 2022, 12:09 PM
Herald added subscribers: • benschac, atul, • adrian, tomek. · View Herald TranscriptFeb 16 2022, 12:09 PM
• jim edited the summary of this revision. (Show Details)Feb 16 2022, 12:10 PM
Harbormaster completed remote builds in B6899: Diff 9750.Feb 16 2022, 12:13 PM
• jim requested review of this revision.Feb 16 2022, 12:13 PM
• jim added a child revision: D3234: tunnelbroker: Merge tunnelbroker-base and tunnelbroker-server images.Feb 16 2022, 12:20 PM
• karol requested changes to this revision.Feb 18 2022, 6:29 AM

I checked and it works.

How does this work? Does docker-compose automatically sources .env file? Looks like it but correct me if I'm wrong. This is cool, I didn't know about this!

Passing back to your queue to get answers but the idea looks great!

services/scripts/run_server_image.sh
38

Why exactly do we resign from this information? This is the only one place where we get informed in the console on which port the service's going to be run.

This revision now requires changes to proceed.Feb 18 2022, 6:29 AM
• jim added a comment.Feb 18 2022, 9:30 AM

Yes, it doesn't actually source into environment variables but parses it as a file. So if you actually set the environment variables, they will override whatever is in the file. And for different configurations you can pass the --env-file flag explicitly. See https://docs.docker.com/compose/env-file/.

services/scripts/run_server_image.sh
38

I didn't think it was a big deal as you can query the port mapping with docker-compose port (this actually seems to not work but hopefully they fix the bug in a future docker-compose release), docker port, docker ps, docker-compose config or however you choose. And part of what I'm trying to do is move away from ad-hoc scripts for executing stuff and configure docker-compose so that it can be called directly.

But if you like seeing the port map in the script, we could do something like

docker-compose up $SERVICE-server &
echo "Running $SERVICE service with port mappings:"
docker-compose port $SERVICE-server
fg %1

which prints

Running tunnelbroker service with port mappings:
50051/tcp -> 0.0.0.0:50051
50051/tcp -> :::50051
• max accepted this revision.Feb 21 2022, 6:43 AM

Overall great idea. Accepting this.

ashoat added a comment.Feb 21 2022, 11:07 PM

@jimpo, when responding to "Request changes" you should select "Re-request review" from the dropdown at the bottom. That way the diff goes to your reviewer's queue again, instead of being stuck on your queue. (This is why the status of the diff is currently "Needs Revision".)

ashoat added inline comments.Feb 21 2022, 11:09 PM
services/scripts/run_server_image.sh
38

(@karol-bisztyga, it looks like the only open question for you is whether you think @jimpo should add the lines above to print the port mapping)

• jim requested review of this revision.Feb 23 2022, 3:46 PM

Yes, waiting for response from @karol-bisztyga

• karol accepted this revision.Feb 25 2022, 12:27 AM
This revision is now accepted and ready to land.Feb 25 2022, 12:27 AM
Herald added 1 blocking reviewer(s): ashoat. · View Herald TranscriptFeb 25 2022, 12:27 AM
This revision now requires review to proceed.Feb 25 2022, 12:27 AM
ashoat accepted this revision.Feb 25 2022, 12:38 PM
This revision is now accepted and ready to land.Feb 25 2022, 12:38 PM
Closed by commit rCOMM90ddba6307b1: services: Use .env file for docker-compose (authored by • jim). · Explain WhyFeb 25 2022, 2:38 PM
This revision was automatically updated to reflect the committed changes.
• jim added a commit: rCOMM90ddba6307b1: services: Use .env file for docker-compose.

Revision Contents
Changeset List

Diff 9750

View Options

services/.env

#include "DatabaseManager.h" #include "DatabaseManager.h"
#include "Constants.h" #include "Constants.h"
#include "Tools.h"
#include <aws/core/utils/Outcome.h> #include <aws/core/utils/Outcome.h>
#include <aws/dynamodb/model/DeleteItemRequest.h>
#include <aws/dynamodb/model/QueryRequest.h> #include <aws/dynamodb/model/QueryRequest.h>
#include <aws/dynamodb/model/ScanRequest.h> #include <aws/dynamodb/model/ScanRequest.h>
#include <aws/dynamodb/model/DeleteItemRequest.h>
#include <iostream> #include <iostream>
namespace comm { namespace comm {
namespace network { namespace network {
namespace database { namespace database {
DatabaseManager &DatabaseManager::getInstance() { DatabaseManager &DatabaseManager::getInstance() {
Show All 21 Linesvoid DatabaseManager::innerRemoveItem(
const Aws::DynamoDB::Model::DeleteItemOutcome &outcome = const Aws::DynamoDB::Model::DeleteItemOutcome &outcome =
getDynamoDBClient()->DeleteItem(request); getDynamoDBClient()->DeleteItem(request);
if (!outcome.IsSuccess()) { if (!outcome.IsSuccess()) {
throw std::runtime_error(outcome.GetError().GetMessage()); throw std::runtime_error(outcome.GetError().GetMessage());
} }
} }
void DatabaseManager::putBackupItem(const BackupItem &item) {
ashoatUnsubmitted
Not Done
Inline Actions

This automatically inserts the new item into the secondary index, right?

ashoat: This automatically inserts the new item into the secondary index, right?
karolAuthorUnsubmitted
Done
Inline Actions

Yes

Whenever the data in the table is modified, the index is automatically changed to reflect the changes in the table.

karol: Yes > Whenever the data in the table is modified, the index is automatically changed to…
Aws::DynamoDB::Model::PutItemRequest request;
request.SetTableName(BackupItem::tableName);
request.AddItem(
BackupItem::FIELD_USER_ID,
Aws::DynamoDB::Model::AttributeValue(item.getUserID()));
request.AddItem(
BackupItem::FIELD_CREATED,
Aws::DynamoDB::Model::AttributeValue(
std::to_string(getCurrentTimestamp())));
request.AddItem(
BackupItem::FIELD_BACKUP_ID,
Aws::DynamoDB::Model::AttributeValue(item.getBackupID()));
request.AddItem(
BackupItem::FIELD_RECOVERY_DATA,
Aws::DynamoDB::Model::AttributeValue(item.getRecoveryData()));
request.AddItem(
BackupItem::FIELD_COMPACTION_HOLDER,
Aws::DynamoDB::Model::AttributeValue(item.getCompactionHolder()));
request.AddItem(
BackupItem::FIELD_ATTACHMENT_HOLDERS,
Aws::DynamoDB::Model::AttributeValue(item.getAttachmentHolders()));
this->innerPutItem(std::make_shared<BackupItem>(item), request);
}
std::shared_ptr<BackupItem>
DatabaseManager::findLastBackupItem(const std::string &userID) {
std::shared_ptr<BackupItem> item = createItemByType<BackupItem>();
Aws::DynamoDB::Model::QueryRequest req;
req.SetTableName(BackupItem::tableName);
req.SetKeyConditionExpression(item->getPrimaryKey() + " = :valueToMatch");
AttributeValues attributeValues;
attributeValues.emplace(":valueToMatch", userID);
req.SetExpressionAttributeValues(attributeValues);
req.SetIndexName("userID-created-index");
req.SetLimit(1);
req.SetScanIndexForward(false);
const Aws::DynamoDB::Model::QueryOutcome &outcome =
getDynamoDBClient()->Query(req);
if (!outcome.IsSuccess()) {
throw std::runtime_error(outcome.GetError().GetMessage());
}
const Aws::Vector<AttributeValues> &items = outcome.GetResult().GetItems();
if (items.empty()) {
return nullptr;
}
return std::make_shared<database::BackupItem>(items[0]);
}
void DatabaseManager::removeBackupItem(std::shared_ptr<BackupItem> item) {
ashoatUnsubmitted
Not Done
Inline Actions

This automatically removes the item from the secondary index, right?

ashoat: This automatically removes the item from the secondary index, right?
karolAuthorUnsubmitted
Done
Inline Actions

Yes

Whenever the data in the table is modified, the index is automatically changed to reflect the changes in the table.

karol: Yes > Whenever the data in the table is modified, the index is automatically changed to…
Aws::DynamoDB::Model::DeleteItemRequest request;
request.SetTableName(item->getTableName());
request.AddKey(
BackupItem::FIELD_USER_ID,
Aws::DynamoDB::Model::AttributeValue(item->getUserID()));
request.AddKey(
BackupItem::FIELD_BACKUP_ID,
Aws::DynamoDB::Model::AttributeValue(item->getBackupID()));
const Aws::DynamoDB::Model::DeleteItemOutcome &outcome =
comm::network::getDynamoDBClient()->DeleteItem(request);
if (!outcome.IsSuccess()) {
throw std::runtime_error(outcome.GetError().GetMessage());
}
}
} // namespace database } // namespace database
} // namespace network } // namespace network
} // namespace comm } // namespace comm
View Options

services/scripts/build_base_image.sh

#include "DatabaseManager.h" #include "DatabaseManager.h"
#include "Constants.h" #include "Constants.h"
#include "Tools.h"
#include <aws/core/utils/Outcome.h> #include <aws/core/utils/Outcome.h>
#include <aws/dynamodb/model/DeleteItemRequest.h>
#include <aws/dynamodb/model/QueryRequest.h> #include <aws/dynamodb/model/QueryRequest.h>
#include <aws/dynamodb/model/ScanRequest.h> #include <aws/dynamodb/model/ScanRequest.h>
#include <aws/dynamodb/model/DeleteItemRequest.h>
#include <iostream> #include <iostream>
namespace comm { namespace comm {
namespace network { namespace network {
namespace database { namespace database {
DatabaseManager &DatabaseManager::getInstance() { DatabaseManager &DatabaseManager::getInstance() {
Show All 21 Linesvoid DatabaseManager::innerRemoveItem(
const Aws::DynamoDB::Model::DeleteItemOutcome &outcome = const Aws::DynamoDB::Model::DeleteItemOutcome &outcome =
getDynamoDBClient()->DeleteItem(request); getDynamoDBClient()->DeleteItem(request);
if (!outcome.IsSuccess()) { if (!outcome.IsSuccess()) {
throw std::runtime_error(outcome.GetError().GetMessage()); throw std::runtime_error(outcome.GetError().GetMessage());
} }
} }
void DatabaseManager::putBackupItem(const BackupItem &item) {
ashoatUnsubmitted
Not Done
Inline Actions

This automatically inserts the new item into the secondary index, right?

ashoat: This automatically inserts the new item into the secondary index, right?
karolAuthorUnsubmitted
Done
Inline Actions

Yes

Whenever the data in the table is modified, the index is automatically changed to reflect the changes in the table.

karol: Yes > Whenever the data in the table is modified, the index is automatically changed to…
Aws::DynamoDB::Model::PutItemRequest request;
request.SetTableName(BackupItem::tableName);
request.AddItem(
BackupItem::FIELD_USER_ID,
Aws::DynamoDB::Model::AttributeValue(item.getUserID()));
request.AddItem(
BackupItem::FIELD_CREATED,
Aws::DynamoDB::Model::AttributeValue(
std::to_string(getCurrentTimestamp())));
request.AddItem(
BackupItem::FIELD_BACKUP_ID,
Aws::DynamoDB::Model::AttributeValue(item.getBackupID()));
request.AddItem(
BackupItem::FIELD_RECOVERY_DATA,
Aws::DynamoDB::Model::AttributeValue(item.getRecoveryData()));
request.AddItem(
BackupItem::FIELD_COMPACTION_HOLDER,
Aws::DynamoDB::Model::AttributeValue(item.getCompactionHolder()));
request.AddItem(
BackupItem::FIELD_ATTACHMENT_HOLDERS,
Aws::DynamoDB::Model::AttributeValue(item.getAttachmentHolders()));
this->innerPutItem(std::make_shared<BackupItem>(item), request);
}
std::shared_ptr<BackupItem>
DatabaseManager::findLastBackupItem(const std::string &userID) {
std::shared_ptr<BackupItem> item = createItemByType<BackupItem>();
Aws::DynamoDB::Model::QueryRequest req;
req.SetTableName(BackupItem::tableName);
req.SetKeyConditionExpression(item->getPrimaryKey() + " = :valueToMatch");
AttributeValues attributeValues;
attributeValues.emplace(":valueToMatch", userID);
req.SetExpressionAttributeValues(attributeValues);
req.SetIndexName("userID-created-index");
req.SetLimit(1);
req.SetScanIndexForward(false);
const Aws::DynamoDB::Model::QueryOutcome &outcome =
getDynamoDBClient()->Query(req);
if (!outcome.IsSuccess()) {
throw std::runtime_error(outcome.GetError().GetMessage());
}
const Aws::Vector<AttributeValues> &items = outcome.GetResult().GetItems();
if (items.empty()) {
return nullptr;
}
return std::make_shared<database::BackupItem>(items[0]);
}
void DatabaseManager::removeBackupItem(std::shared_ptr<BackupItem> item) {
ashoatUnsubmitted
Not Done
Inline Actions

This automatically removes the item from the secondary index, right?

ashoat: This automatically removes the item from the secondary index, right?
karolAuthorUnsubmitted
Done
Inline Actions

Yes

Whenever the data in the table is modified, the index is automatically changed to reflect the changes in the table.

karol: Yes > Whenever the data in the table is modified, the index is automatically changed to…
Aws::DynamoDB::Model::DeleteItemRequest request;
request.SetTableName(item->getTableName());
request.AddKey(
BackupItem::FIELD_USER_ID,
Aws::DynamoDB::Model::AttributeValue(item->getUserID()));
request.AddKey(
BackupItem::FIELD_BACKUP_ID,
Aws::DynamoDB::Model::AttributeValue(item->getBackupID()));
const Aws::DynamoDB::Model::DeleteItemOutcome &outcome =
comm::network::getDynamoDBClient()->DeleteItem(request);
if (!outcome.IsSuccess()) {
throw std::runtime_error(outcome.GetError().GetMessage());
}
}
} // namespace database } // namespace database
} // namespace network } // namespace network
} // namespace comm } // namespace comm
View Options

services/scripts/run_all_services.sh

#include "DatabaseManager.h" #include "DatabaseManager.h"
#include "Constants.h" #include "Constants.h"
#include "Tools.h"
#include <aws/core/utils/Outcome.h> #include <aws/core/utils/Outcome.h>
#include <aws/dynamodb/model/DeleteItemRequest.h>
#include <aws/dynamodb/model/QueryRequest.h> #include <aws/dynamodb/model/QueryRequest.h>
#include <aws/dynamodb/model/ScanRequest.h> #include <aws/dynamodb/model/ScanRequest.h>
#include <aws/dynamodb/model/DeleteItemRequest.h>
#include <iostream> #include <iostream>
namespace comm { namespace comm {
namespace network { namespace network {
namespace database { namespace database {
DatabaseManager &DatabaseManager::getInstance() { DatabaseManager &DatabaseManager::getInstance() {
Show All 21 Linesvoid DatabaseManager::innerRemoveItem(
const Aws::DynamoDB::Model::DeleteItemOutcome &outcome = const Aws::DynamoDB::Model::DeleteItemOutcome &outcome =
getDynamoDBClient()->DeleteItem(request); getDynamoDBClient()->DeleteItem(request);
if (!outcome.IsSuccess()) { if (!outcome.IsSuccess()) {
throw std::runtime_error(outcome.GetError().GetMessage()); throw std::runtime_error(outcome.GetError().GetMessage());
} }
} }
void DatabaseManager::putBackupItem(const BackupItem &item) {
ashoatUnsubmitted
Not Done
Inline Actions

This automatically inserts the new item into the secondary index, right?

ashoat: This automatically inserts the new item into the secondary index, right?
karolAuthorUnsubmitted
Done
Inline Actions

Yes

Whenever the data in the table is modified, the index is automatically changed to reflect the changes in the table.

karol: Yes > Whenever the data in the table is modified, the index is automatically changed to…
Aws::DynamoDB::Model::PutItemRequest request;
request.SetTableName(BackupItem::tableName);
request.AddItem(
BackupItem::FIELD_USER_ID,
Aws::DynamoDB::Model::AttributeValue(item.getUserID()));
request.AddItem(
BackupItem::FIELD_CREATED,
Aws::DynamoDB::Model::AttributeValue(
std::to_string(getCurrentTimestamp())));
request.AddItem(
BackupItem::FIELD_BACKUP_ID,
Aws::DynamoDB::Model::AttributeValue(item.getBackupID()));
request.AddItem(
BackupItem::FIELD_RECOVERY_DATA,
Aws::DynamoDB::Model::AttributeValue(item.getRecoveryData()));
request.AddItem(
BackupItem::FIELD_COMPACTION_HOLDER,
Aws::DynamoDB::Model::AttributeValue(item.getCompactionHolder()));
request.AddItem(
BackupItem::FIELD_ATTACHMENT_HOLDERS,
Aws::DynamoDB::Model::AttributeValue(item.getAttachmentHolders()));
this->innerPutItem(std::make_shared<BackupItem>(item), request);
}
std::shared_ptr<BackupItem>
DatabaseManager::findLastBackupItem(const std::string &userID) {
std::shared_ptr<BackupItem> item = createItemByType<BackupItem>();
Aws::DynamoDB::Model::QueryRequest req;
req.SetTableName(BackupItem::tableName);
req.SetKeyConditionExpression(item->getPrimaryKey() + " = :valueToMatch");
AttributeValues attributeValues;
attributeValues.emplace(":valueToMatch", userID);
req.SetExpressionAttributeValues(attributeValues);
req.SetIndexName("userID-created-index");
req.SetLimit(1);
req.SetScanIndexForward(false);
const Aws::DynamoDB::Model::QueryOutcome &outcome =
getDynamoDBClient()->Query(req);
if (!outcome.IsSuccess()) {
throw std::runtime_error(outcome.GetError().GetMessage());
}
const Aws::Vector<AttributeValues> &items = outcome.GetResult().GetItems();
if (items.empty()) {
return nullptr;
}
return std::make_shared<database::BackupItem>(items[0]);
}
void DatabaseManager::removeBackupItem(std::shared_ptr<BackupItem> item) {
ashoatUnsubmitted
Not Done
Inline Actions

This automatically removes the item from the secondary index, right?

ashoat: This automatically removes the item from the secondary index, right?
karolAuthorUnsubmitted
Done
Inline Actions

Yes

Whenever the data in the table is modified, the index is automatically changed to reflect the changes in the table.

karol: Yes > Whenever the data in the table is modified, the index is automatically changed to…
Aws::DynamoDB::Model::DeleteItemRequest request;
request.SetTableName(item->getTableName());
request.AddKey(
BackupItem::FIELD_USER_ID,
Aws::DynamoDB::Model::AttributeValue(item->getUserID()));
request.AddKey(
BackupItem::FIELD_BACKUP_ID,
Aws::DynamoDB::Model::AttributeValue(item->getBackupID()));
const Aws::DynamoDB::Model::DeleteItemOutcome &outcome =
comm::network::getDynamoDBClient()->DeleteItem(request);
if (!outcome.IsSuccess()) {
throw std::runtime_error(outcome.GetError().GetMessage());
}
}
} // namespace database } // namespace database
} // namespace network } // namespace network
} // namespace comm } // namespace comm
View Options

services/scripts/run_server_image.sh

#include "DatabaseManager.h" #include "DatabaseManager.h"
#include "Constants.h" #include "Constants.h"
#include "Tools.h"
#include <aws/core/utils/Outcome.h> #include <aws/core/utils/Outcome.h>
#include <aws/dynamodb/model/DeleteItemRequest.h>
#include <aws/dynamodb/model/QueryRequest.h> #include <aws/dynamodb/model/QueryRequest.h>
#include <aws/dynamodb/model/ScanRequest.h> #include <aws/dynamodb/model/ScanRequest.h>
#include <aws/dynamodb/model/DeleteItemRequest.h>
#include <iostream> #include <iostream>
namespace comm { namespace comm {
namespace network { namespace network {
namespace database { namespace database {
DatabaseManager &DatabaseManager::getInstance() { DatabaseManager &DatabaseManager::getInstance() {
Show All 21 Linesvoid DatabaseManager::innerRemoveItem(
const Aws::DynamoDB::Model::DeleteItemOutcome &outcome = const Aws::DynamoDB::Model::DeleteItemOutcome &outcome =
getDynamoDBClient()->DeleteItem(request); getDynamoDBClient()->DeleteItem(request);
if (!outcome.IsSuccess()) { if (!outcome.IsSuccess()) {
throw std::runtime_error(outcome.GetError().GetMessage()); throw std::runtime_error(outcome.GetError().GetMessage());
} }
} }
void DatabaseManager::putBackupItem(const BackupItem &item) {
ashoatUnsubmitted
Not Done
Inline Actions

This automatically inserts the new item into the secondary index, right?

ashoat: This automatically inserts the new item into the secondary index, right?
karolAuthorUnsubmitted
Done
Inline Actions

Yes

Whenever the data in the table is modified, the index is automatically changed to reflect the changes in the table.

karol: Yes > Whenever the data in the table is modified, the index is automatically changed to…
Aws::DynamoDB::Model::PutItemRequest request;
request.SetTableName(BackupItem::tableName);
request.AddItem(
BackupItem::FIELD_USER_ID,
Aws::DynamoDB::Model::AttributeValue(item.getUserID()));
request.AddItem(
BackupItem::FIELD_CREATED,
Aws::DynamoDB::Model::AttributeValue(
std::to_string(getCurrentTimestamp())));
request.AddItem(
BackupItem::FIELD_BACKUP_ID,
Aws::DynamoDB::Model::AttributeValue(item.getBackupID()));
request.AddItem(
BackupItem::FIELD_RECOVERY_DATA,
Aws::DynamoDB::Model::AttributeValue(item.getRecoveryData()));
request.AddItem(
BackupItem::FIELD_COMPACTION_HOLDER,
Aws::DynamoDB::Model::AttributeValue(item.getCompactionHolder()));
request.AddItem(
BackupItem::FIELD_ATTACHMENT_HOLDERS,
Aws::DynamoDB::Model::AttributeValue(item.getAttachmentHolders()));
this->innerPutItem(std::make_shared<BackupItem>(item), request);
}
std::shared_ptr<BackupItem>
DatabaseManager::findLastBackupItem(const std::string &userID) {
std::shared_ptr<BackupItem> item = createItemByType<BackupItem>();
Aws::DynamoDB::Model::QueryRequest req;
req.SetTableName(BackupItem::tableName);
req.SetKeyConditionExpression(item->getPrimaryKey() + " = :valueToMatch");
AttributeValues attributeValues;
attributeValues.emplace(":valueToMatch", userID);
req.SetExpressionAttributeValues(attributeValues);
req.SetIndexName("userID-created-index");
req.SetLimit(1);
req.SetScanIndexForward(false);
const Aws::DynamoDB::Model::QueryOutcome &outcome =
getDynamoDBClient()->Query(req);
if (!outcome.IsSuccess()) {
throw std::runtime_error(outcome.GetError().GetMessage());
}
const Aws::Vector<AttributeValues> &items = outcome.GetResult().GetItems();
if (items.empty()) {
return nullptr;
}
return std::make_shared<database::BackupItem>(items[0]);
}
void DatabaseManager::removeBackupItem(std::shared_ptr<BackupItem> item) {
ashoatUnsubmitted
Not Done
Inline Actions

This automatically removes the item from the secondary index, right?

ashoat: This automatically removes the item from the secondary index, right?
karolAuthorUnsubmitted
Done
Inline Actions

Yes

Whenever the data in the table is modified, the index is automatically changed to reflect the changes in the table.

karol: Yes > Whenever the data in the table is modified, the index is automatically changed to…
Aws::DynamoDB::Model::DeleteItemRequest request;
request.SetTableName(item->getTableName());
request.AddKey(
BackupItem::FIELD_USER_ID,
Aws::DynamoDB::Model::AttributeValue(item->getUserID()));
request.AddKey(
BackupItem::FIELD_BACKUP_ID,
Aws::DynamoDB::Model::AttributeValue(item->getBackupID()));
const Aws::DynamoDB::Model::DeleteItemOutcome &outcome =
comm::network::getDynamoDBClient()->DeleteItem(request);
if (!outcome.IsSuccess()) {
throw std::runtime_error(outcome.GetError().GetMessage());
}
}
} // namespace database } // namespace database
} // namespace network } // namespace network
} // namespace comm } // namespace comm
View Options

services/scripts/services_config.sh

Loading...
View Options

services/scripts/test_service.sh

Loading...