如何将步骤函数结果传递给eventbridge put事件

Question

使用步骤函数放置事件，我想将发送到步骤的数据传递到事件桥，然后将相同的精确输入传递到下一个步骤。

ingest_sfn["flatten_metadata"] = sfn.Pass(
self,
f"Flatten Metadata",
input_path="$.metadata.result",
result_path="$.metadata",
)
ingest_sfn["put_event"] = sfn_tasks.EventBridgePutEvents(self, "Put Event",
entries=[sfn_tasks.EventBridgePutEventsEntry(
detail=sfn.TaskInput.from_object({
}),
event_bus=event_bus_base,
detail_type="MessageFromStepFunctions",
source="step.function"
)],

result_path="$",
output_path="$"
)

result_path的结果＝"$"。元数据"；应该是我在put事件步骤上的输入和输出。

Answer 1

答案是使用

result_path=sfn.JsonPath.DISCARD

这将把输入传递到下一步，就像它进入您的步骤一样。