diff --git a/.gitignore b/.gitignore
index 1e9fc3a..d25bdfe 100755
--- a/.gitignore
+++ b/.gitignore
@@ -2,8 +2,9 @@
 **/builds/**
 
 lambda_golang/landing
-lambda_golang/story
+lambda_golang/stories
 lambda_golang/landing_metadata
+lambda_golang/story
 venv
 
 # Binaries for programs and plugins
diff --git a/cloud_environments/terraform.sh b/cloud_environments/terraform.sh
index c882829..0414f72 100755
--- a/cloud_environments/terraform.sh
+++ b/cloud_environments/terraform.sh
@@ -21,6 +21,7 @@ if (
     cd $GOLANG_SRC_DIR && \
     go build ./cmd/landing && \
     go build ./cmd/landing_metadata && \
+    go build ./cmd/stories && \
     go build ./cmd/story && \
     cd $PYTHON_SRC_DIR && python -m compileall layer src
 ); then
diff --git a/cloud_module/api.tf b/cloud_module/api.tf
index db1daa0..6e7603f 100755
--- a/cloud_module/api.tf
+++ b/cloud_module/api.tf
@@ -93,29 +93,11 @@ module "slack_command_lambda" {
     }
   }
 
-  # allow lambda to invoke step function
-  attach_policy_json = true
-  policy_json        = <<EOF
-{
-    "Version": "2012-10-17",
-    "Statement": [
-        {
-            "Effect": "Allow",
-            "Action": [
-                "states:StartExecution"
-            ],
-            "Resource": ["${module.batch_stories_sfn.state_machine_arn}"]
-        }
-    ]
-}
-EOF
-
   environment_variables = {
     SLACK_SIGNING_SECRET = var.slack_signing_secret
     SLACK_POST_WEBHOOK_URL = var.slack_post_webhook_url
 
     PIPELINE_QUEUE_NAME = module.pipeline_queue.this_sqs_queue_name
-    BATCH_STORIES_SFN_ARN = module.batch_stories_sfn.state_machine_arn
 
     LOGLEVEL = "DEBUG"
     ENV = local.environment
diff --git a/cloud_module/landing_s3_trigger.tf b/cloud_module/landing_s3_trigger.tf
index 22c5bb9..ef0b96d 100644
--- a/cloud_module/landing_s3_trigger.tf
+++ b/cloud_module/landing_s3_trigger.tf
@@ -21,7 +21,7 @@ resource "aws_s3_bucket_notification" "bucket_notification" {
     lambda_function_arn = module.landing_parse_metadata_lambda.lambda_function_arn
     events              = ["s3:ObjectCreated:*"]
     filter_prefix       = "${local.newssite_economy_alias}/"
-    filter_suffix       = ".html"
+    filter_suffix       = "landing.html"
   }
 
   lambda_function {
diff --git a/cloud_module/sfn_def/batch_stories_def.json b/cloud_module/sfn_def/batch_stories_def.json
index e5fa2e7..76194b8 100644
--- a/cloud_module/sfn_def/batch_stories_def.json
+++ b/cloud_module/sfn_def/batch_stories_def.json
@@ -1,18 +1,38 @@
 {
-    "Comment": "Batch processing stories for a landing page",
-    "StartAt": "BatchStoriesFetchParse",
-    "States": {
-      "BatchStoriesFetchParse":{
-        "Comment": "Fetch and parse all stories",
-        "Type":"Task",
-        "Resource": "arn:aws:states:::lambda:invoke",
-        "Parameters":{
-          "FunctionName": "${LANDING_PARSE_METADATA_LAMBDA_ARN}",
-          "Payload": {
-            "landingS3Key.$": "$.landingS3Key"
+  "Comment": "Batch processing stories for a landing page",
+  "StartAt": "Fetch-All",
+  "States": {
+    "Fetch-All": {
+      "Type": "Map",
+      "InputPath": "$",
+      "ItemsPath": "$.stories",
+      "MaxConcurrency": 28,
+      "ResultPath": "$.stories",
+      "Comment": "`Parameters` replaces `InputPath`, see https://docs.aws.amazon.com/step-functions/latest/dg/amazon-states-language-map-state.html ",
+      "Parameters": {
+        "story.$": "$$.Map.Item.Value",
+        "newsSiteAlias.$": "$.newsSiteAlias",
+        "landingPageTimeStamp.$": "$.landingPageTimeStamp"
+      },
+      "Iterator": {
+        "StartAt": "Fetch",
+        "States": {
+          "Fetch": {
+            "Type": "Task",
+            "Resource": "${FETCH_STORY_LAMBDA_ARN}",
+            "Retry" : [
+              {
+                "ErrorEquals": [ "States.Timeout", "Lambda.Unknown" ],
+                "IntervalSeconds": 3,
+                "MaxAttempts": 99,
+                "BackoffRate": 1.5
+              }
+            ],
+            "End": true
           }
-        },
-        "End":true
-     }
+        }
+      },
+      "End": true
     }
   }
+}
\ No newline at end of file
diff --git a/cloud_module/stories_sfn.tf b/cloud_module/stories_sfn.tf
index e88a08c..9bbe4bf 100644
--- a/cloud_module/stories_sfn.tf
+++ b/cloud_module/stories_sfn.tf
@@ -4,7 +4,7 @@ module batch_stories_sfn {
   name = "${local.project_name}-batch-stories-sfn"
 
   definition = templatefile("${path.module}/sfn_def/batch_stories_def.json", {
-    LANDING_PARSE_METADATA_LAMBDA_ARN = module.landing_parse_metadata_lambda.lambda_function_arn
+    FETCH_STORY_LAMBDA_ARN = module.fetch_story_lambda.lambda_function_arn
   })
 
   # allow step function to invoke other service
@@ -14,7 +14,7 @@ module batch_stories_sfn {
   service_integrations = {
     lambda = {
       lambda = [
-        module.landing_parse_metadata_lambda.lambda_function_arn
+        module.fetch_story_lambda.lambda_function_arn
       ]
     }
   }
@@ -91,3 +91,59 @@ module landing_parse_metadata_lambda {
     Project = local.project_name
   }
 }
+
+module fetch_story_lambda {
+  source = "terraform-aws-modules/lambda/aws"
+  create_function = true
+  function_name = "${local.project_name}-fetch-story"
+  description   = "Fetch and archive a story page"
+  handler       = "story"
+  runtime       = "go1.x"
+
+  source_path = [{
+    path = "${path.module}/../lambda_golang/"
+    commands = ["${local.go_build_flags} go build ./cmd/story", ":zip"]
+    patterns = ["story"]
+  }]
+
+  timeout = 900
+  cloudwatch_logs_retention_in_days = 7
+
+  publish = true
+
+  attach_policy_statements = true
+  policy_statements = {
+    s3_archive_bucket = {
+      effect    = "Allow",
+      actions   = [
+        "s3:PutObject",
+        "s3:GetObject"
+      ],
+      resources = [
+        "${data.aws_s3_bucket.archive.arn}/*",
+      ]
+    }
+    # enable getting 404 instead of 403 in case of not found
+    # https://stackoverflow.com/a/19808954/9814131
+    s3_archive_bucket_check_404 = {
+      effect    = "Allow",
+      actions   = [
+        "s3:ListBucket",
+      ],
+      resources = [
+        "${data.aws_s3_bucket.archive.arn}",
+      ]
+    }
+  }
+
+  environment_variables = {
+    SLACK_WEBHOOK_URL = var.slack_post_webhook_url
+    LOG_LEVEL = "DEBUG"
+    DEBUG = "true"
+    S3_ARCHIVE_BUCKET = data.aws_s3_bucket.archive.id
+  }
+
+  tags = {
+    Project = local.project_name
+  }
+}
diff --git a/cloud_module/stories_sqs.tf b/cloud_module/stories_sqs.tf
index f353ad8..a407a90 100644
--- a/cloud_module/stories_sqs.tf
+++ b/cloud_module/stories_sqs.tf
@@ -29,14 +29,14 @@ module "stories_queue_consumer_lambda" {
   source = "terraform-aws-modules/lambda/aws"
 
   create_function = true
-  function_name = "${local.project_name}-stories-queue-consumer-lambda"
-  description   = "Consumes ${local.project_name} stories queue"
-  handler       = "story"
+  function_name = "${local.project_name}-fetch-stories"
+  description   = "Fetch ${local.project_name} stories; triggered by metadata.json creation"
+  handler       = "stories"
   runtime     = "go1.x"
   source_path = [{
     path = "${path.module}/../lambda_golang/"
-    commands = ["${local.go_build_flags} go build ./cmd/story", ":zip"]
-    patterns = ["story"]
+    commands = ["${local.go_build_flags} go build ./cmd/stories", ":zip"]
+    patterns = ["stories"]
   }]
   publish = true
 
@@ -45,6 +45,23 @@ module "stories_queue_consumer_lambda" {
 
   reserved_concurrent_executions = -1
 
+  # allow lambda to invoke step function
+  attach_policy_json = true
+  policy_json        = <<EOF
+{
+    "Version": "2012-10-17",
+    "Statement": [
+        {
+            "Effect": "Allow",
+            "Action": [
+                "states:StartExecution"
+            ],
+            "Resource": ["${module.batch_stories_sfn.state_machine_arn}"]
+        }
+    ]
+}
+EOF
+
   # event source mapping for long polling
   event_source_mapping = {
     sqs = {
@@ -92,6 +109,7 @@ module "stories_queue_consumer_lambda" {
     ENV = local.environment
 
     S3_ARCHIVE_BUCKET = data.aws_s3_bucket.archive.id
+    SFN_ARN = module.batch_stories_sfn.state_machine_arn
   }
 
   tags = {
diff --git a/lambda/src/slack_command_controller.py b/lambda/src/slack_command_controller.py
index 637d420..14a0b75 100755
--- a/lambda/src/slack_command_controller.py
+++ b/lambda/src/slack_command_controller.py
@@ -38,7 +38,7 @@ def lambda_handler(request: APIGatewayRequest, context):
         # https://boto3.amazonaws.com/v1/documentation/api/latest/guide/sqs.html#sending-messages
         queue = sqs.get_queue_by_name(QueueName=PIPELINE_QUEUE_NAME)
         res = queue.send_message(MessageBody=str(request.body), MessageGroupId=f'{PIPELINE_QUEUE_NAME}')
-
+    '''
     elif command.startswith(SlackCommandMantra.FETCH_LANDING_STORIES):
         text = request.body.get('text', '')
         landing_html_key = text[0] if text and isinstance(text, list) else text
@@ -53,6 +53,7 @@ def lambda_handler(request: APIGatewayRequest, context):
             })
         )
         loop.run_until_complete(SlackService.send(f'received landing page key: `{landing_html_key}`'))
+    '''
 
     loop.run_until_complete(SlackService.send(f'You sent a slack command. Processed response: {res}'))
 
diff --git a/lambda_golang/cmd/landing/main.go b/lambda_golang/cmd/landing/main.go
index 18c5240..ecdb4a4 100644
--- a/lambda_golang/cmd/landing/main.go
+++ b/lambda_golang/cmd/landing/main.go
@@ -3,13 +3,9 @@ package main
 import (
 	"context"
 	"fmt"
-	"io"
-	"net/http"
 	"strings"
 	"time"
 
-	"golang.org/x/net/html/charset"
-
 	"github.com/aws/aws-lambda-go/lambda"
 
 	"github.com/rivernews/GoTools"
@@ -33,27 +29,8 @@ type LambdaResponse struct {
 
 func HandleRequest(ctx context.Context, name LambdaEvent) (LambdaResponse, error) {
 	newsSite := newssite.GetNewsSite("NEWSSITE_ECONOMY")
-	resp, err := http.Get(newsSite.LandingURL)
-	if err != nil {
-		// handle error
-		GoTools.Logger("ERROR", err.Error())
-	}
-	defer resp.Body.Close()
-
-	contentType := resp.Header.Get("Content-Type") // Optional, better guessing
-	GoTools.Logger("INFO", "ContentType is ", contentType)
-	utf8reader, err := charset.NewReader(resp.Body, contentType)
-	if err != nil {
-		GoTools.Logger("ERROR", err.Error())
-	}
-
-	body, err := io.ReadAll(utf8reader)
-	if err != nil {
-		// handle error
-		GoTools.Logger("ERROR", err.Error())
-	}
-	bodyText := string(body)
 
+	bodyText := newssite.Fetch(newsSite.LandingURL)
 	GoTools.Logger("INFO", "In golang runtime now!\n\n```\n "+bodyText[:500]+"\n ...```\n End of message")
 
 	// scraper
@@ -61,7 +38,7 @@ func HandleRequest(ctx context.Context, name LambdaEvent) (LambdaResponse, error
 
 	// print out all story titles
 	var slackMessage strings.Builder
-	for i, topic := range result.Topics {
+	for i, topic := range result.Stories {
 		slackMessage.WriteString(topic.Name)
 		slackMessage.WriteString(" ")
 		slackMessage.WriteString(topic.Description)
@@ -76,7 +53,7 @@ func HandleRequest(ctx context.Context, name LambdaEvent) (LambdaResponse, error
 	}
 	GoTools.SendSlackMessage(slackMessage.String())
 
-	successMessage := fmt.Sprintf("Scraper finished - %d links found", len(result.Topics))
+	successMessage := fmt.Sprintf("Scraper finished - %d links found", len(result.Stories))
 	GoTools.Logger("INFO", successMessage)
 
 	// S3 archive
diff --git a/lambda_golang/cmd/landing_metadata/main.go b/lambda_golang/cmd/landing_metadata/main.go
index 24562bc..0d4ff2d 100644
--- a/lambda_golang/cmd/landing_metadata/main.go
+++ b/lambda_golang/cmd/landing_metadata/main.go
@@ -35,11 +35,6 @@ type LambdaResponse struct {
 	Message string `json:"message:"`
 }
 
-type LandingPageMetadata struct {
-	Stories         []newssite.Topic `json:"stories"`
-	UntitledStories []newssite.Topic `json:"untitledstories"`
-}
-
 func HandleRequest(ctx context.Context, s3Event events.S3Event) (LambdaResponse, error) {
 	GoTools.Logger("INFO", "Landing page metadata.json generator launched")
 
@@ -53,8 +48,7 @@ func HandleRequest(ctx context.Context, s3Event events.S3Event) (LambdaResponse,
 		metadataS3Key := fmt.Sprintf("%s/metadata.json", strings.Join(metadataS3DirKeyTokens, "/"))
 
 		result := newssite.GetStoriesFromEconomy(landingPageHtmlText)
-
-		metadataJSONString := newssite.AsJson(LandingPageMetadata{Stories: result.Topics, UntitledStories: result.UntitledTopics})
+		metadataJSONString := GoTools.AsJson(result)
 
 		cloud.Archive(cloud.ArchiveArgs{
 			BodyText:          metadataJSONString,
diff --git a/lambda_golang/cmd/stories/main.go b/lambda_golang/cmd/stories/main.go
new file mode 100644
index 0000000..5181d66
--- /dev/null
+++ b/lambda_golang/cmd/stories/main.go
@@ -0,0 +1,109 @@
+package main
+
+import (
+	"fmt"
+	"strings"
+
+	"github.com/aws/aws-lambda-go/events"
+	"github.com/aws/aws-lambda-go/lambda"
+	"github.com/aws/aws-sdk-go-v2/aws"
+	"github.com/aws/aws-sdk-go-v2/service/sfn"
+
+	"context"
+	"math/rand"
+	"time"
+
+	"github.com/rivernews/GoTools"
+	"github.com/rivernews/media-literacy/pkg/cloud"
+	"github.com/rivernews/media-literacy/pkg/newssite"
+)
+
+func main() {
+	rand.Seed(time.Now().UnixNano())
+	lambda.Start(HandleRequest)
+}
+
+type LambdaResponse struct {
+	OK      bool   `json:"OK:"`
+	Message string `json:"message:"`
+}
+
+var sfnClient *sfn.Client
+
+// SQS event
+// refer to https://github.com/aws/aws-lambda-go/blob/v1.26.0/events/README_SQS.md
+func HandleRequest(ctx context.Context, S3Event events.S3Event) (LambdaResponse, error) {
+	GoTools.Logger("INFO", "Fetch stories lambda launched ... triggered by metadata.json creation.")
+
+	for _, record := range S3Event.Records {
+
+		GoTools.Logger("INFO", fmt.Sprintf("S3 event ``` %s ```\n ", GoTools.AsJson(record)))
+
+		metadataS3KeyTokens := strings.Split(record.S3.Object.URLDecodedKey, "/")
+		newsSiteAlias := metadataS3KeyTokens[0]
+		landingPageTimeStamp := metadataS3KeyTokens[len(metadataS3KeyTokens)-2]
+
+		metadataJSONString := cloud.Pull(record.S3.Object.URLDecodedKey)
+		var metadata newssite.LandingPageMetadata
+		GoTools.FromJson([]byte(metadataJSONString), &metadata)
+
+		GoTools.Logger("INFO", fmt.Sprintf("Test first story: %d:%d", len(metadata.Stories), len(metadata.UntitledStories)))
+
+		// fire step function, input = {stories: [{}, {}, {}...], newsSiteAlias:"", landingPageTimeStamp:""}
+		sfnInput := GoTools.AsJson(&newssite.StepFunctionInput{
+			Stories:              metadata.Stories,
+			NewsSiteAlias:        newsSiteAlias,
+			LandingPageTimeStamp: landingPageTimeStamp,
+		})
+		executionName := strings.ReplaceAll(fmt.Sprintf("%s--%s", landingPageTimeStamp, time.Now().Format(time.RFC3339)), ":", "")
+		sfnArn := GoTools.GetEnvVarHelper("SFN_ARN")
+		GoTools.Logger("INFO", fmt.Sprintf("execName: `%s`\nSfnArn: `%s`\nInput:``` %s ```\n", executionName, sfnArn, sfnInput))
+
+		sfnOutput := cloud.SfnStartExecution(
+			ctx,
+			&sfn.StartExecutionInput{
+				Input:           aws.String(sfnInput),
+				Name:            aws.String(executionName),
+				StateMachineArn: aws.String(sfnArn),
+			},
+		)
+
+		GoTools.Logger("INFO", fmt.Sprintf("Sfn output ``` %s ```\n", GoTools.AsJson(sfnOutput)))
+
+		/*
+			storyChunk := message.Body
+			GoTools.Logger("INFO", fmt.Sprintf("Story consumer! story chunk: %s", storyChunk))
+
+			// TODO: fetch and archive for the chunk of storyURLs
+			storyURLs := strings.Split(storyChunk, " ")
+
+			for _, storyURL := range storyURLs {
+				// TODO: randomized interval
+				time.Sleep(time.Duration(rand.Intn(5)+5) * time.Second)
+
+				storyS3Path := fmt.Sprintf("story/%s", storyURL)
+
+				if !cloud.IsDuplicated(storyS3Path) {
+					GoTools.Logger("INFO", fmt.Sprintf("Archiving story %s", storyURL))
+				} else {
+					GoTools.Logger("DEBUG", fmt.Sprintf("Skip archiving story %s", storyURL))
+				}
+
+				// _, resMessage, err := GoTools.Fetch(GoTools.FetchOption{
+				// 	Method: "GET",
+				// 	URL: "https://ipv4bot.whatismyipaddress.com",
+				// })
+				// if err != nil {
+				// 	GoTools.Logger("ERROR", err.Error())
+				// }
+				// GoTools.Logger("INFO", fmt.Sprintf("%s-%s ip: %s", storyChunkId, storyURL, resMessage))
+			}
+
+		*/
+	}
+
+	return LambdaResponse{
+		OK:      true,
+		Message: "Story consumer fetch parse ok",
+	}, nil
+}
diff --git a/lambda_golang/cmd/story/main.go b/lambda_golang/cmd/story/main.go
index b7220fd..275c9c3 100644
--- a/lambda_golang/cmd/story/main.go
+++ b/lambda_golang/cmd/story/main.go
@@ -1,16 +1,17 @@
 package main
 
 import (
+	"bytes"
 	"fmt"
+	"math/rand"
+	"time"
 
-	"github.com/aws/aws-lambda-go/events"
 	"github.com/aws/aws-lambda-go/lambda"
 
 	"context"
-	"math/rand"
-	"time"
 
 	"github.com/rivernews/GoTools"
+	"github.com/rivernews/media-literacy/pkg/cloud"
 	"github.com/rivernews/media-literacy/pkg/newssite"
 )
 
@@ -24,45 +25,29 @@ type LambdaResponse struct {
 	Message string `json:"message:"`
 }
 
-// SQS event
-// refer to https://github.com/aws/aws-lambda-go/blob/v1.26.0/events/README_SQS.md
-func HandleRequest(ctx context.Context, S3Event events.S3Event) (LambdaResponse, error) {
-	GoTools.Logger("INFO", "Fetch stories lambda launched ... triggered by metadata.json creation.")
-
-	for _, record := range S3Event.Records {
-
-		GoTools.Logger("INFO", fmt.Sprintf("S3 event ``` %s ```\n ", newssite.AsJson(record)))
-		/*
-			storyChunk := message.Body
-			GoTools.Logger("INFO", fmt.Sprintf("Story consumer! story chunk: %s", storyChunk))
-
-			// TODO: fetch and archive for the chunk of storyURLs
-			storyURLs := strings.Split(storyChunk, " ")
-
-			for _, storyURL := range storyURLs {
-				// TODO: randomized interval
-				time.Sleep(time.Duration(rand.Intn(5)+5) * time.Second)
-
-				storyS3Path := fmt.Sprintf("story/%s", storyURL)
-
-				if !cloud.IsDuplicated(storyS3Path) {
-					GoTools.Logger("INFO", fmt.Sprintf("Archiving story %s", storyURL))
-				} else {
-					GoTools.Logger("DEBUG", fmt.Sprintf("Skip archiving story %s", storyURL))
-				}
-
-				// _, resMessage, err := GoTools.Fetch(GoTools.FetchOption{
-				// 	Method: "GET",
-				// 	URL: "https://ipv4bot.whatismyipaddress.com",
-				// })
-				// if err != nil {
-				// 	GoTools.Logger("ERROR", err.Error())
-				// }
-				// GoTools.Logger("INFO", fmt.Sprintf("%s-%s ip: %s", storyChunkId, storyURL, resMessage))
-			}
-
-		*/
-	}
+func HandleRequest(ctx context.Context, stepFunctionMapIterationInput newssite.StepFunctionMapIterationInput) (LambdaResponse, error) {
+	GoTools.Logger("INFO", "Fetch single story launched")
+
+	baseWait := 4
+	waitRange := 100
+	totalWait := rand.Intn(waitRange) + baseWait
+	time.Sleep(time.Duration(totalWait) * time.Second)
+
+	responseBody, _, _ := GoTools.Fetch(GoTools.FetchOption{
+		URL: "https://checkip.amazonaws.com",
+		QueryParams: map[string]string{
+			"format": "json",
+		},
+		Method: "GET",
+	})
+
+	GoTools.Logger("INFO", fmt.Sprintf("IP=`%s` waited %d - %s", bytes.TrimSpace(responseBody), totalWait, stepFunctionMapIterationInput.Story.Name))
+
+	storyHtmlBodyText := newssite.Fetch(stepFunctionMapIterationInput.Story.URL)
+	cloud.Archive(cloud.ArchiveArgs{
+		BodyText: storyHtmlBodyText,
+		Key:      fmt.Sprintf("%s/stories/%s-%s/story.html", stepFunctionMapIterationInput.NewsSiteAlias, stepFunctionMapIterationInput.LandingPageTimeStamp, stepFunctionMapIterationInput.Story.Name),
+	})
 
 	return LambdaResponse{
 		OK:      true,
diff --git a/lambda_golang/go.mod b/lambda_golang/go.mod
index 09f5563..1ca720b 100644
--- a/lambda_golang/go.mod
+++ b/lambda_golang/go.mod
@@ -5,14 +5,19 @@ go 1.19
 require (
 	github.com/PuerkitoBio/goquery v1.7.1
 	github.com/aws/aws-lambda-go v1.26.0
-	github.com/aws/aws-sdk-go-v2 v1.9.0
+	github.com/aws/aws-sdk-go-v2 v1.16.15
 	github.com/aws/aws-sdk-go-v2/config v1.7.0
 	github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.5.0
 	github.com/aws/aws-sdk-go-v2/service/s3 v1.14.0
-	github.com/rivernews/GoTools v0.1.8
+	github.com/rivernews/GoTools v0.2.2
 	golang.org/x/net v0.0.0-20210825183410-e898025ed96a
 )
 
+require (
+	github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.22 // indirect
+	github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.16 // indirect
+)
+
 require (
 	github.com/andybalholm/cascadia v1.2.0 // indirect
 	github.com/aws/aws-sdk-go-v2/credentials v1.4.0 // indirect
@@ -21,9 +26,10 @@ require (
 	github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.3.0 // indirect
 	github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.3.0 // indirect
 	github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.6.0 // indirect
+	github.com/aws/aws-sdk-go-v2/service/sfn v1.14.0
 	github.com/aws/aws-sdk-go-v2/service/sso v1.4.0 // indirect
 	github.com/aws/aws-sdk-go-v2/service/sts v1.7.0 // indirect
-	github.com/aws/smithy-go v1.8.0 // indirect
+	github.com/aws/smithy-go v1.13.3 // indirect
 	github.com/jmespath/go-jmespath v0.4.0 // indirect
 	golang.org/x/text v0.3.6 // indirect
 )
diff --git a/lambda_golang/go.sum b/lambda_golang/go.sum
index 90fef04..aab9b6f 100644
--- a/lambda_golang/go.sum
+++ b/lambda_golang/go.sum
@@ -5,8 +5,9 @@ github.com/andybalholm/cascadia v1.2.0 h1:vuRCkM5Ozh/BfmsaTm26kbjm0mIOM3yS5Ek/F5
 github.com/andybalholm/cascadia v1.2.0/go.mod h1:YCyR8vOZT9aZ1CHEd8ap0gMVm2aFgxBp0T0eFw1RUQY=
 github.com/aws/aws-lambda-go v1.26.0 h1:6ujqBpYF7tdZcBvPIccs98SpeGfrt/UOVEiexfNIdHA=
 github.com/aws/aws-lambda-go v1.26.0/go.mod h1:jJmlefzPfGnckuHdXX7/80O3BvUUi12XOkbv4w9SGLU=
-github.com/aws/aws-sdk-go-v2 v1.9.0 h1:+S+dSqQCN3MSU5vJRu1HqHrq00cJn6heIMU7X9hcsoo=
 github.com/aws/aws-sdk-go-v2 v1.9.0/go.mod h1:cK/D0BBs0b/oWPIcX/Z/obahJK1TT7IPVjy53i/mX/4=
+github.com/aws/aws-sdk-go-v2 v1.16.15 h1:2sInOWGE4HV54R90Pj8QgqBBw3Qf1I0husqbqjPZzys=
+github.com/aws/aws-sdk-go-v2 v1.16.15/go.mod h1:SwiyXi/1zTUZ6KIAmLK5V5ll8SiURNUYOqTerZPaF9k=
 github.com/aws/aws-sdk-go-v2/config v1.7.0 h1:J2cZ7qe+3IpqBEXnHUrFrOjoB9BlsXg7j53vxcl5IVg=
 github.com/aws/aws-sdk-go-v2/config v1.7.0/go.mod h1:w9+nMZ7soXCe5nT46Ri354SNhXDQ6v+V5wqDjnZE+GY=
 github.com/aws/aws-sdk-go-v2/credentials v1.4.0 h1:kmvesfjY861FzlCU9mvAfe01D9aeXcG2ZuC+k9F2YLM=
@@ -15,6 +16,10 @@ github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.5.0 h1:OxTAgH8Y4BXHD6PGCJ8DHx2k
 github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.5.0/go.mod h1:CpNzHK9VEFUCknu50kkB8z58AH2B5DvPP7ea1LHve/Y=
 github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.5.0 h1:zzH1xd1/PX7bFO4/BQwVQP+UcBfYieI1sMH9DA68xZY=
 github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.5.0/go.mod h1:fPU0eFGnS47RyKHHs8BNcCKOm5oOA5xm0BlrZWsQT/A=
+github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.22 h1:pE27/u2A7JlwICjOvONQDob8PToShRTkuiUE74ymVWg=
+github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.22/go.mod h1:/vNv5Al0bpiF8YdX2Ov6Xy05VTiXsql94yUqJMYaj0w=
+github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.16 h1:L5LKGHHXOl4t7+5QZMTl38GIzSAq07XUTRtEquiHGMA=
+github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.16/go.mod h1:62dsXI0BqTIGomDl8Hpm33dv0OntGaVblri3ZRParVQ=
 github.com/aws/aws-sdk-go-v2/internal/ini v1.2.2 h1:d95cddM3yTm4qffj3P6EnP+TzX1SSkWaQypXSgT/hpA=
 github.com/aws/aws-sdk-go-v2/internal/ini v1.2.2/go.mod h1:BQV0agm+JEhqR+2RT5e1XTFIDcAAV0eW6z2trp+iduw=
 github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.3.0 h1:gceOysEWNNwLd6cki65IMBZ4WAM0MwgBQq2n7kejoT8=
@@ -25,28 +30,32 @@ github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.6.0 h1:B/1pIeV/oFnrOwh
 github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.6.0/go.mod h1:LKb3cKNQIMh+itGnEpKGcnL/6OIjPZqrtYah1w5f+3o=
 github.com/aws/aws-sdk-go-v2/service/s3 v1.14.0 h1:nR9j0xMxpXk6orC/C03fbHNrbb1NaXp8LdVV7V1oVLE=
 github.com/aws/aws-sdk-go-v2/service/s3 v1.14.0/go.mod h1:Qit9H3zjAmF7CLHOkrepE9b2ndX/2l3scstsM5g2jSk=
+github.com/aws/aws-sdk-go-v2/service/sfn v1.14.0 h1:a3eqFSw7I2F3cM10LOQyPv9lgfSFMKgVApZwyUAfvwA=
+github.com/aws/aws-sdk-go-v2/service/sfn v1.14.0/go.mod h1:7qXvfThNY35ckGyQ3j3ss2H2lkz9ZZP1bbQNe79rwo4=
 github.com/aws/aws-sdk-go-v2/service/sso v1.4.0 h1:sHXMIKYS6YiLPzmKSvDpPmOpJDHxmAUgbiF49YNVztg=
 github.com/aws/aws-sdk-go-v2/service/sso v1.4.0/go.mod h1:+1fpWnL96DL23aXPpMGbsmKe8jLTEfbjuQoA4WS1VaA=
 github.com/aws/aws-sdk-go-v2/service/sts v1.7.0 h1:1at4e5P+lvHNl2nUktdM2/v+rpICg/QSEr9TO/uW9vU=
 github.com/aws/aws-sdk-go-v2/service/sts v1.7.0/go.mod h1:0qcSMCyASQPN2sk/1KQLQ2Fh6yq8wm0HSDAimPhzCoM=
-github.com/aws/smithy-go v1.8.0 h1:AEwwwXQZtUwP5Mz506FeXXrKBe0jA8gVM+1gEcSRooc=
 github.com/aws/smithy-go v1.8.0/go.mod h1:SObp3lf9smib00L/v3U2eAKG8FyQ7iLrJnQiAmR5n+E=
+github.com/aws/smithy-go v1.13.3 h1:l7LYxGuzK6/K+NzJ2mC+VvLUbae0sL3bXU//04MkmnA=
+github.com/aws/smithy-go v1.13.3/go.mod h1:Tg+OJXh4MB2R/uN61Ko2f6hTZwB/ZYGOtib8J3gBHzA=
 github.com/cpuguy83/go-md2man/v2 v2.0.0-20190314233015-f79a8a8ca69d/go.mod h1:maD7wRr/U5Z6m/iR4s+kqSMx2CaBsrgA7czyZG/E6dU=
 github.com/cpuguy83/go-md2man/v2 v2.0.0/go.mod h1:maD7wRr/U5Z6m/iR4s+kqSMx2CaBsrgA7czyZG/E6dU=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/google/go-cmp v0.5.4/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
-github.com/google/go-cmp v0.5.6 h1:BKbKCqvP6I+rmFHt06ZmyQtvB8xAkWdhFyr0ZUNZcxQ=
 github.com/google/go-cmp v0.5.6/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
+github.com/google/go-cmp v0.5.8 h1:e6P7q2lk1O+qJJb4BtCQXlK8vWEO8V1ZeuEdJNOqZyg=
+github.com/google/go-cmp v0.5.8/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
 github.com/jmespath/go-jmespath v0.4.0 h1:BEgLn5cpjn8UN1mAw4NjwDrS35OdebyEtFe+9YPoQUg=
 github.com/jmespath/go-jmespath v0.4.0/go.mod h1:T8mJZnbsbmF+m6zOOFylbeCJqk5+pHWvzYPziyZiYoo=
 github.com/jmespath/go-jmespath/internal/testify v1.5.1 h1:shLQSRRSCCPj3f2gpwzGwWFoC7ycTf1rcQZHOlsJ6N8=
 github.com/jmespath/go-jmespath/internal/testify v1.5.1/go.mod h1:L3OGu8Wl2/fWfCI6z80xFu9LTZmf1ZRjMHUOPmWr69U=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/rivernews/GoTools v0.1.8 h1:niNLFlg0k4W6zIGrlXrdkL/Cy0yoyMTBIMNmQxPLcnc=
-github.com/rivernews/GoTools v0.1.8/go.mod h1:MUyn34yir1uYn9XUDFnoMwXHANg/DlYyaNMyVK44NQY=
+github.com/rivernews/GoTools v0.2.2 h1:++Rn9ISg47ykzNaDTwYEM55PZDp9fd0VaNCvSGbMOX0=
+github.com/rivernews/GoTools v0.2.2/go.mod h1:rwhBYt6u+VTJwdeAwFkB7ZBMc/RZGvZlf9yJLubIQUI=
 github.com/russross/blackfriday/v2 v2.0.1/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
 github.com/shurcooL/sanitized_anchor_name v1.0.0/go.mod h1:1NzhyTcUVG4SuEtjjoZeVRXNmyL/1OwPU0+IJeTBvfc=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
@@ -63,7 +72,6 @@ golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9sn
 golang.org/x/text v0.3.6 h1:aRYxNxv6iGQlyVaZmk6ZgYEDa+Jg18DxebPSrd6bg1M=
 golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
 golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
-golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4=
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
diff --git a/lambda_golang/pkg/cloud/aws_common.go b/lambda_golang/pkg/cloud/aws_common.go
new file mode 100644
index 0000000..0b8dad7
--- /dev/null
+++ b/lambda_golang/pkg/cloud/aws_common.go
@@ -0,0 +1,32 @@
+package cloud
+
+import (
+	"github.com/aws/aws-sdk-go-v2/aws"
+	"github.com/aws/aws-sdk-go-v2/config"
+
+	"github.com/rivernews/GoTools"
+
+	"context"
+	"sync"
+)
+
+var (
+	awsConfig      aws.Config
+	awsConfigOnce  sync.Once
+	awsConfigError error
+)
+
+func ShareAWSConfig() aws.Config {
+	awsConfigOnce.Do(func() {
+		// Based on
+		// https://aws.github.io/aws-sdk-go-v2/docs/configuring-sdk/
+		awsConfig, awsConfigError = config.LoadDefaultConfig(
+			context.TODO(),
+			config.WithRegion("us-west-2"),
+		)
+		if awsConfigError != nil {
+			GoTools.Logger("ERROR", "AWS shared configuration failed", awsConfigError.Error())
+		}
+	})
+	return awsConfig
+}
diff --git a/lambda_golang/pkg/cloud/s3_common.go b/lambda_golang/pkg/cloud/s3_common.go
index e313ace..86d75fa 100644
--- a/lambda_golang/pkg/cloud/s3_common.go
+++ b/lambda_golang/pkg/cloud/s3_common.go
@@ -1,17 +1,13 @@
 package cloud
 
 import (
-	"github.com/aws/aws-sdk-go-v2/config"
 	"github.com/aws/aws-sdk-go-v2/service/s3"
 
-	"github.com/rivernews/GoTools"
-
-	"context"
 	"sync"
 )
 
 var (
-	s3Client *s3.Client
+	s3Client     *s3.Client
 	s3ClientOnce sync.Once
 )
 
@@ -19,18 +15,8 @@ func SharedS3Client() *s3.Client {
 	// followed
 	// https://stackoverflow.com/a/53504651/9814131
 	s3ClientOnce.Do(func() {
-		// Based on
-		// https://aws.github.io/aws-sdk-go-v2/docs/configuring-sdk/
-		awsConfig, configErr := config.LoadDefaultConfig(
-			context.TODO(),
-			config.WithRegion("us-west-2"),
-		)
-		if configErr != nil {
-			GoTools.Logger("ERROR", "AWS shared configuration failed", configErr.Error())
-		}
-
-		s3Client = s3.NewFromConfig(awsConfig)
+		s3Client = s3.NewFromConfig(ShareAWSConfig())
 	})
 
 	return s3Client
-}
\ No newline at end of file
+}
diff --git a/lambda_golang/pkg/cloud/sfn_common.go b/lambda_golang/pkg/cloud/sfn_common.go
new file mode 100644
index 0000000..2592791
--- /dev/null
+++ b/lambda_golang/pkg/cloud/sfn_common.go
@@ -0,0 +1,34 @@
+package cloud
+
+import (
+	"github.com/aws/aws-sdk-go-v2/service/sfn"
+
+	"github.com/rivernews/GoTools"
+
+	"context"
+	"sync"
+)
+
+var (
+	sfnClient     *sfn.Client
+	sfnClientOnce sync.Once
+)
+
+func SharedSfnClient() *sfn.Client {
+	sfnClientOnce.Do(func() {
+		sfnClient = sfn.NewFromConfig(ShareAWSConfig())
+	})
+	return sfnClient
+}
+
+// refer to real example https://qiita.com/tanaka_takurou/items/bba2e6c32052a636a272
+// SDK doc https://pkg.go.dev/github.com/aws/aws-sdk-go-v2/service/sfn#Client.StartExecution
+func SfnStartExecution(ctx context.Context, sfnInput *sfn.StartExecutionInput) *sfn.StartExecutionOutput {
+	sfnClient = SharedSfnClient()
+
+	output, err := sfnClient.StartExecution(ctx, sfnInput)
+	if err != nil {
+		GoTools.Logger("ERROR", err.Error())
+	}
+	return output
+}
diff --git a/lambda_golang/pkg/newssite/economy.go b/lambda_golang/pkg/newssite/economy.go
index 16a81a4..86f08b5 100644
--- a/lambda_golang/pkg/newssite/economy.go
+++ b/lambda_golang/pkg/newssite/economy.go
@@ -13,12 +13,24 @@ type Topic struct {
 	URL         string `json:"url"`
 }
 
-type GetStoriesFromEconomyResult struct {
-	Topics         []Topic
-	UntitledTopics []Topic
+type LandingPageMetadata struct {
+	Stories         []Topic `json:"stories"`
+	UntitledStories []Topic `json:"untitledstories"`
 }
 
-func GetStoriesFromEconomy(body string) GetStoriesFromEconomyResult {
+type StepFunctionInput struct {
+	Stories              []Topic `json:"stories"`
+	NewsSiteAlias        string  `json:"newsSiteAlias"`
+	LandingPageTimeStamp string  `json:"landingPageTimeStamp"`
+}
+
+type StepFunctionMapIterationInput struct {
+	Story                Topic  `json:"story"`
+	NewsSiteAlias        string `json:"newsSiteAlias"`
+	LandingPageTimeStamp string `json:"landingPageTimeStamp"`
+}
+
+func GetStoriesFromEconomy(body string) LandingPageMetadata {
 	// Load the HTML document
 	doc, err := goquery.NewDocumentFromReader(strings.NewReader(body))
 	if err != nil {
@@ -35,13 +47,13 @@ func GetStoriesFromEconomy(body string) GetStoriesFromEconomyResult {
 	var emptyTitleURLs strings.Builder
 	doc.Find("a[href$=html]").Each(func(i int, anchor *goquery.Selection) {
 		topic := Topic{
-			Name:        strings.TrimSpace(anchor.Text()),
+			Name:        strings.ReplaceAll(strings.TrimSpace(anchor.Text()), "/", "-"),
 			Description: "",
 			URL:         strings.TrimSpace(anchor.AttrOr("href", "-")),
 		}
 		if topic.Name != "" {
 			topics = append(topics, topic)
-			GoTools.Logger("DEBUG", "Found an anchor ", topic.Name, topic.URL)
+			GoTools.Logger("VERBOSE", "Found an anchor ", topic.Name, topic.URL)
 		} else {
 			untitledTopics = append(untitledTopics, topic)
 			emptyTitleURLs.WriteString(topic.URL)
@@ -50,8 +62,8 @@ func GetStoriesFromEconomy(body string) GetStoriesFromEconomyResult {
 	})
 	GoTools.Logger("INFO", "Skipped due to empty title URLs:\n", emptyTitleURLs.String())
 
-	return GetStoriesFromEconomyResult{
-		Topics:         topics,
-		UntitledTopics: untitledTopics,
+	return LandingPageMetadata{
+		Stories:         topics,
+		UntitledStories: untitledTopics,
 	}
 }
diff --git a/lambda_golang/pkg/newssite/utilities.go b/lambda_golang/pkg/newssite/utilities.go
index 11b332f..27c2c9b 100644
--- a/lambda_golang/pkg/newssite/utilities.go
+++ b/lambda_golang/pkg/newssite/utilities.go
@@ -1,9 +1,12 @@
 package newssite
 
 import (
-	"encoding/json"
+	"io"
+	"net/http"
 	"strings"
 
+	"golang.org/x/net/html/charset"
+
 	"github.com/rivernews/GoTools"
 )
 
@@ -27,10 +30,25 @@ func GetNewsSite(envVar string) NewsSite {
 	}
 }
 
-func AsJson(v any) string {
-	jsonBytes, err := json.Marshal(v)
+func Fetch(url string) string {
+	resp, err := http.Get(url)
+	if err != nil {
+		// handle error
+		GoTools.Logger("ERROR", err.Error())
+	}
+	defer resp.Body.Close()
+
+	contentType := resp.Header.Get("Content-Type") // Optional, better guessing
+	GoTools.Logger("DEBUG", "ContentType is ", contentType)
+	utf8reader, err := charset.NewReader(resp.Body, contentType)
+	if err != nil {
+		GoTools.Logger("ERROR", err.Error())
+	}
+
+	body, err := io.ReadAll(utf8reader)
 	if err != nil {
+		// handle error
 		GoTools.Logger("ERROR", err.Error())
 	}
-	return string(jsonBytes)
+	return string(body)
 }