小编Ano*_*ias的帖子

我正在运行pipenv install --dev，这给了我以下错误

Courtesy Notice: Pipenv found itself running within a virtual environment, so it will automatically use that environment, instead of creating its own for any project. You can set PIPENV_IGNORE_VIRTUALENVS=1 to force pipenv to ignore that environment and create its own instead. You can set PIPENV_VERBOSITY=-1 to suppress this warning.
Installing dependencies from Pipfile.lock (2df4c1)…
Failed to load paths: /bin/sh: /Users/XXXX/.local/share/virtualenvs/my-service-enGYxXYk/bin/python: No such file or directory

Output: 
Failed to load paths: /bin/sh: /Users/XXXX/.local/share/virtualenvs/my-service-enGYxXYk/bin/python: No such file …

在我的 CDK 项目中创建了 dynamoDB 表。这很好，它被项目中创建的 lambda 使用。我们需要删除堆栈，这也很好，因为我们已在表上将保留资源设置为 true。

现在，当我尝试全新部署时，我们得到表已存在错误并且堆栈回滚。我需要仅在表不存在时才创建该表的代码。

这是表的基本创建，我在任何地方都找不到有关此问题的任何文档，甚至找不到可以捕获的异常，也找不到在哪里可以看到抛出捕获的异常类型，因为我们只能在 AWS 上的 cloudformation 控制台中看到日志安慰。

 const dynamoTable = new Table(this, "my-table", {
      tableName: StackConfiguration.tableName,
      partitionKey: { name: "id", type: AttributeType.STRING },
    });

我可以检查是否有任何我参考的孩子的数据没有变化没有问题,但我无法找到一种方法来检查该孩子中某个字段是否发生了变化.

这里有一些代码.child("job")不起作用,因为job是字段.这只是我尝试的一些事情.

 Firebase ref = new Firebase(Config.FIREBASE_URL);

        //adding a value event listener so if data in database changes it does in textview also not needed at the minute
        ref.child("Driver").child("Driver2").child("job").addValueEventListener(new ValueEventListener() {
            @Override
            public void onDataChange(DataSnapshot snapshot) {

                for (DataSnapshot postSnapshot : snapshot.getChildren()) {


                    Toast.makeText(ProfileActivity.this, "YEAAA ", Toast.LENGTH_SHORT).show();

                }

            }

            /************had to implement this method****************/
            @Override
            public void onCancelled(FirebaseError firebaseError) {
                System.out.println("The read failed: " + firebaseError.getMessage());

            }
        });

这是数据库中的json

  "Driver" : {
    "Driver1" : {
      "job" : "none",
      "lat" : …

我有一个Spring Boot应用程序，可从Vault中提取秘密，我想在Spring Boot应用程序的应用程序属性文件中使用这些秘密。

def VAR = new groovy.json.JsonSlurper().parseText(secret)[0].VARKEY
if(VAR != ''){
    echo "Vault Secret pulled Successfully pass is "+VAR
}else{
    echo "Vault Secret Not Found"
}

上面的代码成功设置了变量VAR，然后如何使用VAR在Spring Boot应用程序的应用程序属性文件中设置某些值？

谢谢

有大量数据被推送到我们的 Kafka 主题之一，有没有办法确定这些数据来自哪个生产者？

我暂停了我的 Kafka 连接器，重新启动它们时，我的日志中出现了这些错误

[2020-02-19 19:36:00,219] ERROR WorkerSourceTask{id=wem-postgres-source-0} Failed to commit offsets (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter)
************
************
[2020-02-19 19:36:00,216] ERROR WorkerSourceTask{id=wem-postgres-source-0} Failed to flush, timed out while waiting for producer to flush outstanding 2389 messages (org.apache.kafka.connect.runtime.WorkerSourceTask)

随着未完成消息的数量发生变化，我多次收到此错误。然后停了下来，再也没有看到。

我是否需要在此处采取任何措施或 Connect 重试并提交偏移量，这就是错误已停止的原因？

谢谢

我们使用的 sasl 机制是SCRAM-SHA-256但是 kafka 生产者只会接受sasl_mechanismas PLAIN, GSSAPI,OAUTHBEARER

下面的配置会报错

sasl_mechanism must be in PLAIN, GSSAPI, OAUTHBEARER

配置

    ssl_produce = KafkaProducer(bootstrap_servers='brokerCName:9093',
                     security_protocol='SASL_SSL',
                     ssl_cafile='pemfilename.pem',
                     sasl_mechanism='SCRAM-SHA-256',
                     sasl_plain_username='password',
                     sasl_plain_password='secret')

我需要知道如何指定正确的 sasl 机制。

谢谢

我正在通过 CDK 创建 dynamodb 表。

    const table = new dynamodb.Table(this, "my-table", {
      tableName: StackConfiguration.tableName,
      partitionKey: { name: "file_id", type: dynamodb.AttributeType.STRING },
    });

    dynamoReplayTable.addGlobalSecondaryIndex({
      indexName: "processed",
      # ideally would like boolean here but doesn't seem to be an option
      partitionKey: { name: "processed", type: dynamodb.AttributeType.STRING },
    });

然后使用 boto 3 我将数据插入表中，如下所示

    failedRecord = {
        "file_id": str(file_id),
        "processed": "false",
        "payload": str(payload),
        "headers": str(headers),
    }

    table.put_item(Item=failedRecord)

然后，我有另一个服务来读取项目，然后进行处理，我想将已处理的字段（全局二级索引）更新为 true。

我现在有这个代码

    table.update_item(
        Key={"file_id": file_id}, AttributeUpdates={"processed": "true"},
    )

但这会导致以下错误

Parameter validation failed:
Invalid type for parameter …

我正在尝试编写集成测试。我想使用本地堆栈来启动一个模拟 AWS 服务的 docker 容器。

此代码将启动 docker 容器，但不会自动装配来自我的 spring 应用程序的类。

@RunWith(LocalstackTestRunner.class)
@LocalstackDockerProperties(services = {"dynamodb","sns"})
@ActiveProfiles("test")
@SpringBootTest(classes = {TestApplication.class})
public class FlowTest {
    @Autowired
    private PublisherFactory publisherFactory;

    @Test
    public void publishMessage() {
        // publisherFactory is null here 
        Publisher publisher = publisherFactory.getInstance("test-event");
    }
}

此代码将从我的应用程序自动装配类，但不会启动 Docker 容器

@RunWith(SpringRunner.class)
@LocalstackDockerProperties(services = {"dynamodb","sns"})
@ActiveProfiles("test")
@SpringBootTest(classes = {TestApplication.class})
public class FlowTest {
    @Autowired
    private PublisherFactory publisherFactory;

    @Test
    public void publishMessage() {
        //publisher not null here but Docker container not running
        Publisher publisher = publisherFactory.getInstance("test-event");
    } …