|
131 | 131 | "outputs": [],
|
132 | 132 | "source": [
|
133 | 133 | "# Inputs\n",
|
134 |
| - "entity_dir = pload(os.path.join(naas_data_product.OUTPUTS_PATH, \"entities\", \"0\"), \"entity_dir\") or \"\"\n", |
135 |
| - "entity_name = pload(os.path.join(naas_data_product.OUTPUTS_PATH, \"entities\", \"0\"), \"entity_name\") or \"\"\n", |
| 134 | + "entity_index = \"0\"\n", |
| 135 | + "entity_dir = pload(os.path.join(naas_data_product.OUTPUTS_PATH, \"entities\", entity_index), \"entity_dir\") or \"\"\n", |
| 136 | + "entity_name = pload(os.path.join(naas_data_product.OUTPUTS_PATH, \"entities\", entity_index), \"entity_name\") or \"\"\n", |
136 | 137 | "input_dir = os.path.join(entity_dir, \"content-engine\", date.today().isoformat())\n",
|
137 | 138 | "file_name = \"linkedin_posts\"\n",
|
138 | 139 | "\n",
|
139 | 140 | "# Outputs\n",
|
140 |
| - "spreadsheet_url = pload(os.path.join(naas_data_product.OUTPUTS_PATH, \"entities\", \"0\"), \"abi_spreadsheet\") or \"\"\n", |
| 141 | + "spreadsheet_url = pload(os.path.join(naas_data_product.OUTPUTS_PATH, \"entities\", entity_index), \"abi_spreadsheet\") or \"\"\n", |
141 | 142 | "sheet_name = \"POSTS\"\n",
|
142 | 143 | "output_dir = os.path.join(entity_dir, \"content-engine\", date.today().isoformat())\n",
|
143 | 144 | "file_content = \"posts\""
|
|
353 | 354 | },
|
354 | 355 | "outputs": [],
|
355 | 356 | "source": [
|
356 |
| - "df_check = pd.concat([df_init.astype(str), df_content.astype(str)]).drop_duplicates(keep=False)\n", |
357 |
| - "if len(df_check) > 0:\n", |
358 |
| - " gsheet.connect(spreadsheet_url).send(sheet_name=sheet_name, data=df_content, append=False)\n", |
359 |
| - "else:\n", |
360 |
| - " print(\"Noting to update in Google Sheets!\")" |
| 357 | + "send_data_to_gsheet(df_content, df_init, spreadsheet_url, sheet_name)" |
361 | 358 | ]
|
362 | 359 | },
|
363 | 360 | {
|
|
0 commit comments