Bläddra i källkod

s3 path 수정

1.table_name이 site_name보다 먼저 나오도록 수정함
2.object key 이름을 수정함
heewon 3 år sedan
förälder
incheckning
0ef8dd2dd5
1 ändrade filer med 2 tillägg och 2 borttagningar
  1. 2 2
      ambt-preden-wholemigration-dev/ambt-preden-wholemigration-dev.ipynb

+ 2 - 2
ambt-preden-wholemigration-dev/ambt-preden-wholemigration-dev.ipynb

@@ -181,7 +181,7 @@
     "    for row in rows:\n",
     "        data += json.dumps(row, cls=DecimalnDateTimeEncoder) + '\\n'\n",
     "        #logger.info(row)\n",
-    "    object = s3.Object('hdci-ambt-homenetserver-raw','dev/site_name=gurigalmae/table_name=dayenergy/year={}/month={}/ambt-preden-lambda-migration-dev-{}-{}-{}-{}'.format(oldestdate.year, oldestdate.month, oldestdate.year, oldestdate.month, oldestdate.day, str(uuid.uuid4())))\n",
+    "    object = s3.Object('hdci-ambt-homenetserver-raw','dev/table_name=dayenergy/site_name=gurigalmae/year={}/month={}/dayenergy_{}{:02d}{:02d}'.format(oldestdate.year, oldestdate.month, oldestdate.year, oldestdate.month, oldestdate.day))\n",
     "    object.put(Body=data)\n",
     "    oldestdate += timedelta(days=1)"
    ]
@@ -235,7 +235,7 @@
     "    for row in rows:\n",
     "        data += json.dumps(row, cls=DecimalnDateTimeEncoder) + '\\n'\n",
     "        #logger.info(row)\n",
-    "    object = s3.Object('hdci-ambt-homenetserver-raw','dev/site_name=gurigalmae/table_name=monthenergy/year={}/ambt-preden-lambda-migration-dev-{}-{}-{}'.format(oldestdate.year, oldestdate.year, oldestdate.month, str(uuid.uuid4())))\n",
+    "    object = s3.Object('hdci-ambt-homenetserver-raw','dev/site_name=gurigalmae/table_name=monthenergy/year={}/monthenergy_{}{:02d}'.format(oldestdate.year, oldestdate.year, oldestdate.month)\n",
     "    object.put(Body=data)\n",
     "    oldestdate += relativedelta(months=1)"
    ]