|
@@ -3,7 +3,7 @@
|
|
{
|
|
{
|
|
"cell_type": "code",
|
|
"cell_type": "code",
|
|
"execution_count": 22,
|
|
"execution_count": 22,
|
|
- "id": "873b343d",
|
|
|
|
|
|
+ "id": "cded2e4d",
|
|
"metadata": {},
|
|
"metadata": {},
|
|
"outputs": [],
|
|
"outputs": [],
|
|
"source": [
|
|
"source": [
|
|
@@ -16,7 +16,7 @@
|
|
{
|
|
{
|
|
"cell_type": "code",
|
|
"cell_type": "code",
|
|
"execution_count": 23,
|
|
"execution_count": 23,
|
|
- "id": "d78c4890",
|
|
|
|
|
|
+ "id": "9e8e58f3",
|
|
"metadata": {},
|
|
"metadata": {},
|
|
"outputs": [],
|
|
"outputs": [],
|
|
"source": [
|
|
"source": [
|
|
@@ -27,7 +27,7 @@
|
|
{
|
|
{
|
|
"cell_type": "code",
|
|
"cell_type": "code",
|
|
"execution_count": 24,
|
|
"execution_count": 24,
|
|
- "id": "fed62c89",
|
|
|
|
|
|
+ "id": "2a781ebf",
|
|
"metadata": {},
|
|
"metadata": {},
|
|
"outputs": [],
|
|
"outputs": [],
|
|
"source": [
|
|
"source": [
|
|
@@ -37,7 +37,7 @@
|
|
{
|
|
{
|
|
"cell_type": "code",
|
|
"cell_type": "code",
|
|
"execution_count": 25,
|
|
"execution_count": 25,
|
|
- "id": "408876b3",
|
|
|
|
|
|
+ "id": "729af248",
|
|
"metadata": {},
|
|
"metadata": {},
|
|
"outputs": [],
|
|
"outputs": [],
|
|
"source": [
|
|
"source": [
|
|
@@ -47,7 +47,7 @@
|
|
{
|
|
{
|
|
"cell_type": "code",
|
|
"cell_type": "code",
|
|
"execution_count": 26,
|
|
"execution_count": 26,
|
|
- "id": "5bb79584",
|
|
|
|
|
|
+ "id": "e35f6865",
|
|
"metadata": {},
|
|
"metadata": {},
|
|
"outputs": [],
|
|
"outputs": [],
|
|
"source": [
|
|
"source": [
|
|
@@ -72,7 +72,7 @@
|
|
" jsondata[site[jsonpayload['site']]] += json.dumps(jsonpayload) + '\\n' \n",
|
|
" jsondata[site[jsonpayload['site']]] += json.dumps(jsonpayload) + '\\n' \n",
|
|
" for i in site:\n",
|
|
" for i in site:\n",
|
|
" if len(jsondata[site[i]]) != 0:\n",
|
|
" if len(jsondata[site[i]]) != 0:\n",
|
|
- " object = s3.Object('hdci-ambt-wallpad-raw','test2/{}/year={}/month={}/day={}/ambt-preden-lambda-consumer-dev-{}-{}-{}-{}-{}-{}-{}'.format(i, str(year), str(month), str(day), str(year), str(month), str(day), str(hour), str(minute), str(second), str(uuid.uuid4()))) \n",
|
|
|
|
|
|
+ " object = s3.Object('hdci-ambt-wallpad-raw','dev/{}/year={}/month={}/day={}/ambt-preden-lambda-consumer-dev-{}-{}-{}-{}-{}-{}-{}'.format(i, str(year), str(month), str(day), str(year), str(month), str(day), str(hour), str(minute), str(second), str(uuid.uuid4()))) \n",
|
|
" object.put(Body=jsondata.get(site[i]))\n",
|
|
" object.put(Body=jsondata.get(site[i]))\n",
|
|
" #s3.Object(s3BucketName,key).delete()\n",
|
|
" #s3.Object(s3BucketName,key).delete()\n",
|
|
" except ValueError as e:\n",
|
|
" except ValueError as e:\n",
|
|
@@ -82,7 +82,7 @@
|
|
{
|
|
{
|
|
"cell_type": "code",
|
|
"cell_type": "code",
|
|
"execution_count": null,
|
|
"execution_count": null,
|
|
- "id": "bb6d121f",
|
|
|
|
|
|
+ "id": "28127d8e",
|
|
"metadata": {},
|
|
"metadata": {},
|
|
"outputs": [],
|
|
"outputs": [],
|
|
"source": []
|
|
"source": []
|