消息未显示在 SQS 中

Question

我在 lambda 中有以下代码：

  entries = [
        {
            "Id": str(index),
            "MessageAttributes": {},
            "MessageBody": json.dumps(
                to_format(record=record, id_names=IDENTIFIERS, attr_names=ATTRIBUTES, source_names=SOURCE_METADATA)
            ),
            "MessageDeduplicationId": record["message_composite_key"],
            "MessageGroupId": sqs_group_id
        } for index, record in enumerate(records)
    ]
    logger.info(f"{len(entries)} batch entries built")
    queue_url = environ["SQS_QUEUE_URL"]
    try:

        # iterate over entries in batches of 10
        for batch in [entries[index:index + sqs_batch_limit] for index in range(0, len(entries), sqs_batch_limit)]:
            logger.info(f"Sending batch of {len(batch)} records to sqs...")
            sqs.send_message_batch(
                QueueUrl=queue_url,
                Entries=batch
            )
            logger.info("**Sent batch of records to sqs successful**")

由于这条消息，它似乎出错了：

 'InvalidParameterValue', 'Message': 'The request include parameter that is not valid for this queue type'

我在任何地方都找不到 htis 的文档。知道 giong 是什么吗？

Answer 1

MessageDeduplicationIdMessageGroupId根据SQS 参考，不能在标准队列中使用。